nsqjs icon indicating copy to clipboard operation
nsqjs copied to clipboard

Reconnection is not supported

Open 743v45 opened this issue 2 years ago • 2 comments

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.

743v45 avatar Apr 26 '23 15:04 743v45