queued v0.1.1

node-queued

Queued client for Node.js

Example

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

Producer:

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

Consumer:

queue.dequeue({ timeout: 30, wait: 30 }, function (err, item) {
    if (err) throw err;

    console.log(item.value);

    item.complete(function (err) {
        if (err) throw err;
    });
});

Install

npm install queued