From b331c9990a0396301e934daffe095f99d62d1c89 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期三, 27 九月 2023 15:58:49 +0800
Subject: [PATCH] 任务获取修改，状态2只返回已开始和已结束的
---
nsq/consumer.go | 2 ++
1 files changed, 2 insertions(+), 0 deletions(-)
diff --git a/nsq/consumer.go b/nsq/consumer.go
index d7b55e3..f4a2b66 100644
--- a/nsq/consumer.go
+++ b/nsq/consumer.go
@@ -24,6 +24,8 @@
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}
}
c.AddHandler(handler.HandleMessage)
--
Gitblit v1.8.0