Simple Redis Queue for Node.js

Super simple wrapper for redis lpush and brpop commands for basic queue processing and multiple queue support.

Usage

// Require the module
RedisQueue = require("simple-redis-queue");

// Construct a queue with a redis connection
myQueue = new RedisQueue(redisCon);

// Publish to the queue
myQueue.push("queueName", "body string or object", function(err, reply){
    console.log(err);
    console.log("current queue size : " + reply);
});

// Listen for new messages
myQueue.on("message", function (queueName, payload) {
    // Do something with the message
});

// Listen for errors
myQueue.on("error", function (error) {
    console.error(error);
});

// Start monitoring this queue
myQueue.monitor("queueName");

Example Syncronuous Usage

// Require the module
RedisQueue = require("simple-redis-queue");

// Construct a queue with a redis connection
myQueue = new RedisQueue(redisCon);

// Publish to the queue
myQueue.push("queueName", "body string or object", function(err, reply){
    console.log(err);
    console.log("current queue size : " + reply);
});

// Listen for new messages
myQueue.on("message", function (queueName, payload) {
    // Do something with the message
    do_something(some_parameters, function(){
        // callback function
        myQueue.next("queueName");
    });
});

// Listen for errors
myQueue.on("error", function (error) {
    console.error(error);
});

// Start monitoring this queue
myQueue.next("queueName");