zhangzengfei
2023-07-13 89ce2bc6b71ea331c219c295074a289d09c808af
gui/gui.go
@@ -93,8 +93,9 @@
      report.StartReport()
      // 开启订阅
      go nsqclient.InitNsqConsumer(config.Options.QueryTopic, "sensor01", kingdee.QueryMsgHandle)
      // 开启订阅SQL查询
      go nsqclient.InitNsqConsumer(config.Options.SqlQueryTopic, "sensor01", kingdee.SqlQueryHandle)
      go nsqclient.InitNsqConsumer(config.Options.CSTQueryTopic, "sensor01", kingdee.CSTQueryHandle)
      go webserver.Serve(serverPort.Text)
   })