zhangqian
2023-09-01 f4c6c982a275fcdead46a7bdb5704fc39b4f1bb0
nsq/nsq.go
@@ -41,5 +41,9 @@
      _ = Consume(fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })
   safe.Go(func() {
      _ = Consume(fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })
   return nil
}