From 302c591ca77dd4fb2b6e373d9912b91ee88f89f5 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期三, 23 八月 2023 12:58:56 +0800
Subject: [PATCH] 下发工艺参数时使用nsq获取工艺参数
---
nsq/msg_handler.go | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go
index a33cf9f..1274aa1 100644
--- a/nsq/msg_handler.go
+++ b/nsq/msg_handler.go
@@ -126,3 +126,23 @@
}
return nil
}
+
+type ProcessParams struct {
+ Topic string
+}
+
+func (slf *ProcessParams) HandleMessage(data []byte) (err error) {
+ logx.Infof("get an process params message :%s", data)
+ var resp = new(common.ResponseProcessParams)
+ err = json.Unmarshal(data, &resp)
+ if err != nil {
+ logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
+ return err
+ }
+ //閫氱煡鍥炲鏀跺埌
+ ReceivedMessageChan <- &ReceivedMessage{
+ Topic: slf.Topic,
+ Message: data,
+ }
+ return nil
+}
--
Gitblit v1.8.0