Wraps nsq.js into an easy to use interface
npm install nsqubicle
Read messages using
pull and write messages using
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.
Per default nsqubicle broadcast all messages to a
broadcast topic as well.
You can read these messages by calling
pull without a topic