amqp-worker

node-amqp-worker

Quick Start

var lib = require('amqp-worker');
var Client = lib.Client;
var Worker = lib.Worker;
 
var client = new Client('amqp://localhost');
 
var worker = new Worker('queue_name', function(msg, callback) {
  // do stuff with msg
  if (err) {
    // nack the message
    return callback(err);
  }
 
  // ack the message
  callback(null, result);
});
 
worker.on('complete', function(data) {
  // this worker's handler completed a message
  console.log(data);
});
 
client.addWorker(worker);
 
client.on('complete', function(data) {
  // a worker handler completed a message
  console.log(data);
});
 
client.connect(function() {
  console.log('workers started');
});

For more details, see the example.