crontask/cron_task.go
@@ -130,6 +130,7 @@ IsFinish: record.IsFinish, FinishAmount: finishAmount, ProductProcedureID: record.ProductProcedureID, Ts: record.Ts, } caller := nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicTaskProcedureStatusUpdate, conf.Conf.NsqConf.NodeId), "") err = caller.Send(msg)
