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