From 21e0e02fd465fef04f1834b078c621a0e3594308 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 02 九月 2023 16:51:48 +0800
Subject: [PATCH] 任务开始和结束都发送消息通知apsserver

---
 nsq/caller.go |   11 +++++++++++
 1 files changed, 11 insertions(+), 0 deletions(-)

diff --git a/nsq/caller.go b/nsq/caller.go
index 59c6848..ed0dbdd 100644
--- a/nsq/caller.go
+++ b/nsq/caller.go
@@ -49,3 +49,14 @@
 		}
 	}
 }
+
+func (caller *DefaultCaller) Send(input interface{}) error {
+	msg, err := json.Marshal(input)
+	if err != nil {
+		return err
+	}
+	producer := GetProducer()
+	err = producer.Publish(caller.RequestTopic, msg)
+	return err
+
+}

--
Gitblit v1.8.0