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 = require('amqplib-easy')('amqp://foo:bar@amqp.lol');
 
amqp.consume(
  {
    exchange: 'cat',
    queue: 'found_cats',
    topics: [ 'found.*' ]
  },
  function (cat) {
    console.log('Found a cat named', cat.json.name);
  }
);
 
amqp.publish({ exchange: 'cat' }, 'found.tawny', { name: 'Sally' });
 
amqp.sendToQueue({ queue: 'found_cats' }, { name: 'Fred' });

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.sendToQueue({ queue: 'found_cats' }, { name: 'Fred' })
  .then(function () { console.log('sent to queue'); })
  .catch(function (err) { console.error('sending failed', err); });

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

require('diehard').listen();

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.