queued

Queued client library

node-queued

Queued client for Node.js

var queued = require('queued');
var client = queued('http://localhost:5353');
var queue = client.queue('foo');

Producer:

queue.enqueue("foo", function (erritem) {
    ...
});

Consumer:

queue.dequeue({ timeout: 30, wait: 30 }, function (erritem) {
    if (err) throw err;
 
    console.log(item.value);
 
    item.complete(function (err) {
        if (err) throw err;
    });
});
npm install queued