nsq/nsq.go @@ -89,5 +89,5 @@ func Stop() { defaultConsumerManager.stop() StopProducer() //StopProducer() }