启停生产者

zhangqian

2023-10-21 578b74f9de4b96e88e2fddb726c7c6f78162b033

启停生产者

 nsq/nsq.go

@@ -23,17 +23,12 @@
    defaultConsumerManager = new(consumerManager)
}

var producerStarted bool

func (c *consumerManager) init() error {
    if len(conf.Conf.NsqConf.NodeId) <= 0 {
        return errors.New("no NodeId")
    }
    if !producerStarted {
        if err := initProducer(); err != nil {
            return err
        }
        producerStarted = true
    if err := initProducer(); err != nil {
        return err
    }
    var topics = []string{
        constvar.NsqTopicScheduleTask,