nsqubicle
Wraps nsq.js into an easy to use interface
npm install nsqubicle
Usage
Read messages using pull
and write messages using push
var nsq = ;var queue =;queue;queue;
The options map is passed directly to nsq.js as well. In addition to the regular nsq options you can pass
namespace: 'namespace-topics-with-me'broadcast: true // set to false to disable broadcasting
If you call the callback with an error the message will be requeued.
Broadcasting
Per default nsqubicle broadcast all messages to a broadcast
topic as well.
You can read these messages by calling pull
without a topic
queue;
License
MIT