nsqjs
nsqjs copied to clipboard
Reconnection is not supported
const nsq = require('./lib/nsq')
const reader = new nsq.Reader('test', 'test', {
nsqdTCPAddresses: [
'10.0.6.88:41501',
],
})
reader.on('message', msg => {
console.log('Received message [%s]: %s', msg.id, msg.body.toString())
msg.finish()
})
reader.connect()
setTimeout(() => {
reader.close();
}, 1000);
setTimeout(() => {
reader.connect();
}, 2000);
When reader.close() is executed, isClosed = true is irreversible.