任务开始和结束都发送消息通知apsserver

zhangqian

2023-09-02 21e0e02fd465fef04f1834b078c621a0e3594308

 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

}