Multiple queue

queue.js

function subscribe(queue) {
  logger.info('API logger queue created.');
  queue.bind('ingestion', '#');

  var options = { ack : true, prefetchCount : 1000 };

  queue.subscribe(options, function (payload, headers, deliveryInfo, message) {
    importer.log(payload, function (err) {
      try {
        if (err) message.reject(true); // requeue the message
        else message.acknowledge(false); // acknowledge only this message
      } catch (e) {
        logger.error('Error acknowledging queue message', { err : e });
      }
    });
  });
}