Roger Rabbit
Roger Rabbit is a module that makes the process of consuming and publishing messages in message brokers easier. It is a wrapper for amqplib.
Install
npm install roger-rabbit --save
Example
// broker.jsconst Broker = ; moduleexports = ;
// consumer.jsconst broker = ; const queue = name: 'queue.name' options: durable: true ; const routingKey = 'routing.key.name'; broker;
// publisher.jsconst broker = ; broker ;
Documentation
Broker
Option | Description | Required | Default |
---|---|---|---|
host | message broker connection url | yes | null |
logger | logger object | no | console |
disableLog | disable log (all levels) | no | false |
exchange | exchange options | no | null |
queue | queue options | no | null |
Exchange options
Option | Description | Default |
---|---|---|
type | direct, topic, fanout | empty string (deafault) |
name | exchange name | null |
options | options used in assertExchange | null |
Queue options
Option | Description | Default |
---|---|---|
name | queue name | null |
options | options used in assertQueue | null |
broker.consume
broker.consume
expects to receive an object with consumers options and routing key name and callback. Example:
const broker = ; const queue = name: 'queue.name' options: durable: true ; const routingKey = 'routing.key.name'; broker;
broker.publish
broker.publish
expects to receive routing key, message and publish options. Example:
const options = persistent: true exchange: name: 'exchange.name' ; broker ;
broker.sendToQueue
broker.sendToQueue
expects to receive queue name, message and publish options. Example:
const queue = options: {}; broker ;