启停生产者

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,