@vk/queue

RabbitMQ client wrapper for NetAgent services.

Features

• Connection management with auto-reconnect.
• Typed message publishing and consumption.
• Dead Letter Exchange (DLX) support.

Usage

import { RabbitMQClient } from '@vk/queue'

const client = new RabbitMQClient(config.RABBITMQ_URL)
await client.connect()

await client.publish('my_exchange', 'routing_key', { some: 'data' })

await client.consume('my_queue', async (msg) => {
  console.log(msg)
})