nsq-wrapper

Wrapper for nsqjs to easily subscribe to multiple topics

const NSQ_Wrapper = require('nsq-wrapper')

const wrapper = new NSQ_Wrapper('channel', {
    topic1: function (msg, topic) {
        msg.finish();
    }
}, {
    nsqdHost: 'localhost',
    nsqdPort: '4150',
    nsqlookupdHost: 'localhost',
    nsqlookupdPort: '4161'
});

wrapper.connect().then(function () {
    wrapper.publish('topic1', { foo: 'bar' });
});