This is a very opinionated abstraction over amqplib to help simplify the implementation of PubSub messaging patterns on RabbitMQ.
!IMPORTANT! - bk-rabbitmq-pubsub needs nodejs >= 8.x.
- Publish event on a channel with data
- Subscribe event from a channel and receive data
- Attempt to gracefully handle lost connections and channels
- Connections have a backoff policy of exponential delay randomized: ~1s, ~2s, ~4s, ~8s then stable at ~8s, ~8s...
npm install bk-rabbitmq-pubsub
const RabbitmqPubSub = require('bk-rabbitmq-pubsub');
const pubsub = new RabbitmqPubSub();
// subscribe on the channel myEvent
pubsub.subscribe('myEvent', (data) => {
console.log(data);
})
// publish event with data on channel MyEvent
pubsub.publish('myEvent', data);
Return a new RabbitmqPubSub pubsub client.
options
are :
url
: URL to connect to RabbitMQ (default :amqp://guest:guest@localhost:5672/
)logLevel
: Log level (default :info
)logName
: Log name for Bunyan = (default :RabbitmqRPC
)exchangeName
: Exchange name for handle RPC request (default :RabbitmqRPC
)log
: Custom log instance (require to implement function trace, debug, info, warn and error)subscribeQueueName
: The name for the subscribeQueue, by default it's generated
Subscribe on a channel.
options
are :
channelName
: Name of the channel to subscribe. (throw an error if undefined or null)data
: Data send with the event for the subscribers.
Subscribe on a channel.
options
are :
channelName
: Name of the channel to subscribe. (throw an error if undefined or null)listener
: The function call when an event arrive. The function take one arg whose is the data send by the publisher. This method return a number. This number is the subscription ID
Unsubscribe on a channel the specific listener.
options
are :
channelName
: Name of the channel to unsubscribe. (throw an error if undefined or null)listener
: The listner function to unsubscribe.
Unsubscribe a specific subscription ID.
options
are :
subscriptionId
: Id of the subscription.
Remove all listener for a specific channel.
options
are :
channelName
: Name of the channel to unsubscribe all function. (throw an error if undefined or null)
First off, thanks for your interest and for wanting to contribute! PRs with insufficient coverage, broken tests or deviation from the style will not be accepted.
# With docker
npm run build-image #to build rabbitmq Image
npm run start-image #to start rabbitmq on localhost
# Or provide your own local rabbitmq install
# run tests
npm test
# run lint
npm run lint
# run coverage
npm run coverage
- Add better coverage test (unsubscribe, unsubscribeAll, ...)
- Add better support for lost connection
- ...
MIT License
Copyright (c) 2017 Beekast