关闭nsq时也关闭生产者

zhangqian

2023-10-21 15f1cdb2c358d1c120b5ab4bc28ef596e3d93b80

 nsq/nsq.go

@@ -89,4 +89,5 @@

func Stop() {
   defaultConsumerManager.stop()
   StopProducer()
}