停止消费时关闭tcp连接

zhangqian

2023-10-20 7276ab65576ec73b439a40d7f1a3035a534b968c

 nsq/nsq.go

@@ -73,8 +73,8 @@
         nsqclient.DestroyNsqConsumer(consumer)
         logx.Infof("try stop consumer, topic : %v", key)
         consumer = nil
         c.clients.Delete(key)
      }

      return true
   })
}