fix

zhangqian

2023-08-27 8dfb8feb32bb5e4e460e23dcde42612a26fa2bcb

 nsq/consumer.go

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

import (
   "apsClient/conf"
   "apsClient/constvar"
   "apsClient/pkg/logx"
   "apsClient/pkg/nsqclient"
   "context"
@@ -17,8 +18,12 @@
   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}
   }
   c.AddHandler(handler.HandleMessage)