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