amqp-worker v0.0.1

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.