zhangzengfei
2023-08-04 88da1e13a073e8b5656387a246d827593fbd6163
main.go
@@ -30,6 +30,9 @@
   // 初始化nsq
   nsqclient.InitNsqProducer()
   // 订阅设备变更
   nsqclient.InitNsqConsumer(config.Options.SubDeviceTopic, "sensor01", collector.HandleDeviceUpdate)
   collector.InitTask()
   select {}