nsq/producer.go @@ -12,6 +12,10 @@ return producer } func StopProducer() { nsqclient.DestroyProducerPool() } func initProducer() (err error) { producer, err = nsqclient.NewProducer(conf.Conf.NsqConf.NsqdAddr) if err != nil {
