crontask/cron_task.go
@@ -160,6 +160,12 @@ if err != nil { logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg) } msg = &common.MsgPullDataRequest{DataType: common.PullDataTypeProcessModelPlcAddress} caller = nsq.NewCaller(fmt.Sprintf(constvar.NsqTopicPullDataRequest, conf.Conf.NsqConf.NodeId), constvar.NsqTopicPullDataResponse) err = caller.Send(msg) if err != nil { logx.Errorf("send pull data msg error:%v, msg:%+v", err.Error(), msg) } } func QueryClusterStatus() {
