当前使用的工艺编号置顶

zhangqian

2023-10-09 dad1ae79fe78e770d88f41713b4c68fad562d9ef

 nsq/consumer.go

@@ -2,6 +2,7 @@

import (
   "apsClient/conf"
   "apsClient/constvar"
   "apsClient/pkg/logx"
   "apsClient/pkg/nsqclient"
   "context"
@@ -17,8 +18,16 @@
   logx.Infof("Consume NewNsqConsumer topic:%v", topic)
   var handler MsgHandler
   switch topic {
   case fmt.Sprintf("aps.%v.scheduleTask", conf.Conf.NsqConf.NodeId):
   case fmt.Sprintf(constvar.NsqTopicScheduleTask, conf.Conf.NsqConf.NodeId):
      handler = new(ScheduleTask)
   case fmt.Sprintf(constvar.NsqTopicSendPlcAddress, conf.Conf.NsqConf.NodeId):
      handler = &PlcAddress{Topic: topic}
   case fmt.Sprintf(constvar.NsqTopicProcessParamsResponse, conf.Conf.NsqConf.NodeId):
      handler = &ProcessParams{Topic: topic}
   case fmt.Sprintf(constvar.NsqTopicApsProcessParams, conf.Conf.NsqConf.NodeId):
      handler = &ProcessParamsSync{Topic: topic}
   case fmt.Sprintf(constvar.NsqTopicDeviceUpdate, conf.Conf.NsqConf.NodeId):
      handler = &DeviceUpdate{Topic: topic}
   }
   c.AddHandler(handler.HandleMessage)