zhangqian
2023-08-22 369026325416d187b7b0a0fbe8b5fd1895515bbb
nsq/nsq.go
@@ -37,5 +37,9 @@
      _ = Consume(fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })
   safe.Go(func() {
      _ = Consume(fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId), conf.Conf.System.DeviceId)
   })
   return nil
}