zhangqian
2023-10-20 bc7ee359dfe4e66a05c2cca9deb7a945534009f3
nsq/nsq.go
@@ -34,7 +34,6 @@
   var topics = []string{
      constvar.NsqTopicScheduleTask,
      constvar.NsqTopicSendPlcAddress,
      constvar.NsqTopicProcessParamsResponse,
      constvar.NsqTopicApsProcessParams,
      constvar.NsqTopicDeviceUpdate,
      constvar.NsqTopicPullDataResponse,
@@ -73,7 +72,9 @@
      if consumer, ok := value.(*nsqclient.NsqConsumer); ok {
         nsqclient.DestroyNsqConsumer(consumer)
         logx.Infof("try stop consumer, topic : %v", key)
         consumer = nil
      }
      return true
   })
}