Very basic node module for creating and consuming from RabbitMQ work queues

Because I am writing a lot of small services that use this sort of queue. It is just a light rabbit.js wrapper (if for some weird reason you were hoping to use this project, I would instead you use that library directly) that defaults to persistant queues and automatically reconnects on connection failures.

var rabbitWorker = require('rabbit-worker');
var worker = new rabbitWorker.Worker('localhost', 'work_queue_1', function (message, ack) {
    console.log('got message', message);
    ack();					//important! Signals to the queue that the work has been completed
});
	
var tasker = new rabbitWorker.Tasker('localhost', 'work_queue_1');
if (tasker.isReady()) {
    tasker.publish('New message');
} else {
    tasker.once('ready', tasker.publish.bind(tasker, 'New message');
} 

• Support for publisher confirms would be rad (I am currently living dangerously and not using them in the interest of code simplicity). Would require either a modification in the upstream rabbit.js library or that this module be converted to use amqplib as its upstream library directly (amqplib being the core module that rabbit.js relies on).

Light wrapper over the rabbit module to easily create persistent workers and taskers.

Version: 0.0.1
Author: notnarb

• rabbit-worker
  • ~Worker(rabbitserver, routingKey, workerFunction)
  • ~Tasker(rabbitserver, routingKey) ⇐ event.EventEmitter
    • .publish(message)
    • .isReady() ⇒ Boolean

connects to the specified rabbitmq server as a worker for the specified routing key

Kind: inner method of rabbit-worker

Example

var worker = new Worker('localhost', 'work_queue_1', function (message, ack) {
    console.log('got message', message);
    ack();					//important! Signals to the queue that the work has been completed
})

connects to the specified rabbitmq server as a publisher for the specified routing key. Emits a 'ready' event when it can start taking publish commands.

Kind: inner method of rabbit-worker
Extends: event.EventEmitter

Example

var tasker = new Tasker('localhost', 'work_queue_1');
if (tasker.isReady()) {
    tasker.publish('New message');
} else {
    tasker.once('ready', tasker.publish.bind(tasker, 'New message');
} 

• ~Tasker(rabbitserver, routingKey) ⇐ event.EventEmitter
  • .publish(message)
  • .isReady() ⇒ Boolean

Publishes a message to the queue

Kind: instance method of Tasker
Throws:

• Error - if the queue is currently unavailable, this throws an error

Checks to see if the tasker is currently connected to the queue

Kind: instance method of Tasker
Returns: Boolean - - true if currently can accept publish arguments