While doing a connection close, there is an Channel Inactive which is un-caught. Hence, the connection is not removed.
So I'm left with a stale connection, and not able to reconnect due to an existing entry to that address.
Logs:
16:14:47.245 INFO Remove connection server:4150 - NSQConsumer.connect
16:14:47.245 INFO Closing connection: com.github.brainlag.nsq.Connection@188fe003 - Connection.close
16:14:47.246 INFO Channel disconnected! com.github.brainlag.nsq.Connection@188fe003 - NSQHandler.channelInactive
While doing a connection close, there is an Channel Inactive which is un-caught. Hence, the connection is not removed. So I'm left with a stale connection, and not able to reconnect due to an existing entry to that address.
Logs: 16:14:47.245 INFO Remove connection server:4150 - NSQConsumer.connect 16:14:47.245 INFO Closing connection: com.github.brainlag.nsq.Connection@188fe003 - Connection.close 16:14:47.246 INFO Channel disconnected! com.github.brainlag.nsq.Connection@188fe003 - NSQHandler.channelInactive
Fix could be to put in try catch
https://github.com/brainlag/JavaNSQClient/blob/d0e6612afac2731d0ed10ff5b12f75429149db48/src/main/java/com/github/brainlag/nsq/NSQConsumer.java#L204