var queued = require('queued');
var client = queued('http://localhost:5353', { auth: '...' });
var queue = client.queue('testing');

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

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