nsq/msg_handler.go
@@ -3,7 +3,7 @@ import ( "apsClient/conf" "apsClient/model" "apsClient/model/request" "apsClient/model/common" "apsClient/pkg/logx" "apsClient/pkg/structx" "encoding/json" @@ -19,7 +19,7 @@ func (slf *ScheduleTask) HandleMessage(data []byte) (err error) { logx.Infof("get an message :%s", data) var tasks = make([]*request.DeliverScheduleTask, 0) var tasks = make([]*common.DeliverScheduleTask, 0) err = json.Unmarshal(data, &tasks) if err != nil { logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
