The AMQP (Advanced Message Queuing Protocol) adapter for @quatrain/queue.
This adapter enables communication with AMQP 0-9-1 brokers such as RabbitMQ. It is ideal for high-throughput, low-latency messaging requirements where you have full control over the broker infrastructure.
npm install @quatrain/queue-amqp amqplib
# or
yarn add @quatrain/queue-amqp amqplib
Register the adapter by providing the connection URL for your AMQP broker.
import { Queue } from '@quatrain/queue'
import { AmqpQueueAdapter } from '@quatrain/queue-amqp'
const amqpAdapter = new AmqpQueueAdapter({
config: {
url: 'amqp://user:password@localhost:5672',
// Optional: specify an exchange if not using default
exchange: 'quatrain-exchange'
}
})
Queue.addAdapter('rabbitmq', amqpAdapter, true)
For concrete examples and usage guides, please refer to the How-To Guide.
AGPL-3.0-only