zhangqian
2023-09-02 74f8cd07a39795656573d4e4bb2fe85a6dadbb8c
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
}