amqp-pubsub

Minimalist abstraction layer for amqp jobs implementations.

Installation

npm install amqp-jobs

Usage

Queue work items

var amqp = require('amqp');
var jobs = require('../');

var connection = amqp.createConnection({ host: "localhost" });

connection.on('ready', function() {
  var job = jobs(connection, 'amqp-jobs-example');

  job.queue({ text : 'hello world' });
});

Worker

var amqp = require('amqp');
var jobs = require('../');

var connection = amqp.createConnection({ host: "localhost" });

connection.on('ready', function() {
  var job = jobs(connection, 'amqp-jobs-example');

  var generateError = false;

  job.worker(function(message, next) {
    // Do the work. Call next without err to acknowledge msg or pass an error do not acknowledge message
    next();
  });
});