Jackrabbit

RabbitMQ in Node.js without hating life.

Forked to fix issues with reconnecting.

Simple Example

producer.js:

var jackrabbit = require('@daanzu/jackrabbit');
var rabbit = jackrabbit(process.env.RABBIT_URL);

rabbit
  .default()
  .publish('Hello World!', { key: 'hello' })
  .on('drain', rabbit.close);

consumer.js:

var jackrabbit = require('@daanzu/jackrabbit');
var rabbit = jackrabbit(process.env.RABBIT_URL);

rabbit
  .default()
  .queue({ name: 'hello' })
  .consume(onMessage, { noAck: true });

function onMessage(data) {
  console.log('received:', data);
}

consumer-reconnecting.js:

function consume_ampq (queue_name, callback) {
  var jackrabbit = require('@daanzu/jackrabbit');
  var rabbit = jackrabbit(process.env.RABBIT_URL);
  rabbit
    .default()
    .queue({ name: queue_name, durable: true })
    .consume((data, ack, nack, msg) => {
      console.log(`Received data: ${data}`);
      if (callback) callback(data);
      ack();
    });
  let reconnecting_timeout = null;
  rabbit.on('error', (err) => {
    if (err) console.log(`Rabbit error: ${err}`);
    if (!reconnecting_timeout) {
      console.log(`Pausing before reconnecting...`);
      reconnecting_timeout = setTimeout(() => {
        console.log(`Attempting to reconnect...`);
        consume_ampq(queue_name, callback);
      }, 5000);
    }
  });
  console.log(`Consuming ${queue_name}...`);
}
consume_ampq('hello', (data) => console.log('in callback'));

Ack/Nack Consumer Example

var jackrabbit = require('@daanzu/jackrabbit');
var rabbit = jackrabbit(process.env.RABBIT_URL);

rabbit
  .default()
  .queue({ name: 'important_job' })
  .consume(function(data, ack, nack, msg) {
    // process data...
    // and ACK on success
    ack();
    // or alternatively NACK on failure
    nack();
  })

Jackrabbit is designed for simplicity and an easy API. If you're an AMQP expert and want more power and flexibility, check out wascally.

More Examples

For now, the best usage help is can be found in examples, which map 1-to-1 with the official RabbitMQ tutorials.

Installation

npm install --save daanzu/jackrabbit

Tests

The tests are set up with Docker + Docker-Compose, so you don't need to install rabbitmq (or even node) to run them:

$ docker-compose run jackrabbit npm test

If using Docker-Machine on OSX:

$ docker-machine start
$ eval "$(docker-machine env default)"
$ docker-compose run jackrabbit npm test