关闭nsq时也关闭生产者

zhangqian

2023-10-21 15f1cdb2c358d1c120b5ab4bc28ef596e3d93b80

关闭nsq时也关闭生产者

 nsq/nsq.go

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

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

 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 {