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) })