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