fix consumer stop

nsqio · Jun 28, 2021 · 7230676 · 7230676
1 parent d07dcb0
commit 7230676
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/consumer.go b/consumer.go
@@ -734,6 +734,11 @@ func (r *Consumer) onConnClose(c *Conn) {
 
 	// we were the last one (and stopping)
 	if atomic.LoadInt32(&r.stopFlag) == 1 {
+		_, opened := <-r.reconnectStopChan
+		if left == 0 && !opened {
+			r.stopHandlers()
+		}
+
 		return
 	}