amqplib-retry

amqplib-retry

Retry failed attempts to consume a message, with increasing delays between each attempt.

Installation (via npm)

$ npm install amqplib-retry --save

Usage

(function () {
  'use strict';

  var Promise = require('bluebird'),
    amqplib = require('amqplib'),
    retry = require('amqplib-retry'),
    CONSUMER_QUEUE = 'example-queue',
    FAILURE_QUEUE = 'example-queue.failure';

  Promise.resolve(amqplib.connect('amqp://localhost:5672'))
    .then(function (conn) {
      return conn.createChannel();
    })
    .tap(function (channel) {
      return Promise.all([
        channel.assertQueue(CONSUMER_QUEUE, {durable: false, autoDelete: true}),
        channel.assertQueue(FAILURE_QUEUE, {durable: false, autoDelete: true})
      ]);
    })
    .tap(function (channel) {

      var messageHandler = function (msg) {
        // no need to 'ack' or 'nack' messages
        // messages that generate an exception (or a rejected promise) will be retried
        console.log(msg);
      };

      channel.consume(CONSUMER_QUEUE, retry({
        channel: channel,
        consumerQueue: CONSUMER_QUEUE,
        failureQueue: FAILURE_QUEUE,
        handler: messageHandler
        //delay: function (attempts) { return 1000; /* milliseconds */ }
      }));

    });

}());

License

MIT License

Author

Lanetix ([e-mail])