Reconnection is not supported

[743v45]

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.

[fw42]

Did you find a solution to this?

[743v45]

@fw42 Try starting a new instance. This appears to be a feature used only to close the program.