easy to use module for nsq
Wraps nsq.js into an easy to use interface
npm install nsqubicle
Read messages using
pull and write messages using
var nsq = require'nsqubicle';var queue = nsqnsqd: '127.0.0.1:4150'channel: 'my-channel';queuepull'test'console.log'we have pulled a message!' message;callback; // we are done with the message;queuepush'test' hello:'world';
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
queuepullconsole.log'someone pushed to' topic 'with message' message;callback;;