Redis queue worker

Redis queue worker watching redis list for messages.

Install

npm install redis-queue-worker

Use

var Worker = require('redis-queue-worker');

var queues = ['queue'], // One or multiple queues to watch.
    options = {}, // check out source for default options to override (optional).
    redisOptions = {}; // npm redis package options (optional).

var w = new Worker(queues, options, redisOptions);

w.on('error', function(err){
    console.log(err);
});

w.on('message', function(queue, data) {
    console.log(queue); // Queue name the message dropped in.
    console.log(data); // Redis data string or json if possible to parse.
});

w.start(); // Start reading messages from queue.

w.stop(); // Stop reding messages from queue.