ReadonlynameThe name of the store (e.g. 'mongodb', 'redis', 'dynamodb')
ReadonlylibraryThe client library being used
Returns the underlying amqplib channel for operations not wrapped here.
Returns the underlying amqplib connection.
Declare a queue, creating it if it doesn't exist (idempotent). Returns
amqplib's assertion reply ({ queue, messageCount, consumerCount }).
Pass '' as queue to have the broker generate a unique name.
Optionaloptions: anyDeclare an exchange of the given type ('direct', 'fanout',
'topic', 'headers'), creating it if it doesn't exist (idempotent).
Optionaloptions: anyBind queue to exchange so messages published to exchange matching
pattern (the routing/binding key) are routed into queue.
Send a message straight to a named queue (via the default exchange).
Non-Buffer messages are serialized — strings UTF-8 encoded, other
values JSON.stringify'd (see the module docs). Returns amqplib's
boolean write result (false when the channel's write buffer is full
and you should wait for a 'drain' event before writing more).
Optionaloptions: anyPublish a message to an exchange with a routingKey; the exchange
routes it to bound queues. Non-Buffer messages are serialized like
sendToQueue(). Returns amqplib's boolean write result.
Optionaloptions: anyRegister handler to receive each message delivered from queue. The
handler is called with the raw amqplib message object (or null if the
consumer is cancelled by the broker); decode msg.content yourself.
Unless options.noAck is set, call ack(msg)/nack(msg) when done.
Returns amqplib's { consumerTag } reply.
Optionaloptions: anyAcknowledge a delivered message so the broker can drop it.
OptionalallUpTo: booleanReject a delivered message. By default RabbitMQ requeues it (requeue
defaults to true in amqplib); pass requeue = false to drop or
dead-letter it.
OptionalallUpTo: booleanOptionalrequeue: booleanSet the consumer prefetch (QoS) — the max number of unacknowledged messages the broker will deliver to consumers on this channel at once.
Optionalglobal: boolean
RabbitMQStorewraps a singleamqplibchannel and exposes RabbitMQ's core AMQP operations: asserting queues/exchanges, binding them, publishing (to a queue directly or via an exchange), consuming with ack/nack, and consumer prefetch (QoS).