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