Closed wgxoln closed 5 years ago
when call NsqConsumer.close(), the consumer is down, but the connection between consumer and nsq is still connected. so we can call connection.close() after receive CLS reply in cleanClose.
when call NsqConsumer.close(), the consumer is down, but the connection between consumer and nsq is still connected. so we can call connection.close() after receive CLS reply in cleanClose.