amqplib-easy
amqplib but easy! Let us manage your channels, connections, assertions and bindings for you, so you can just send messages.
Installation
npm install --save amqplib-easy
Usage
var amqp = 'amqp://foo:bar@amqp.lol'; amqp; amqp; amqp;
yields
Found a cat named Sally
Found a cat named Fred
API
Logging
All methods return a promise, so you can attach logging to them via the following.
amqp ;
Connection Cleanup
diehard is used for cleaning up connections before the process exits. To ensure connections are cleaned up,
npm install --save diehard
and in your application's entry point, add
;
You can also explicitly close all connections by calling require('amqplib-easy').close()
. You may pass a callback to this function which will be invoked once all connections have been closed.