获取工艺参数用nsq方式获取

zhangqian

2023-08-22 369026325416d187b7b0a0fbe8b5fd1895515bbb

 nsq/msg_handler.go

@@ -126,3 +126,23 @@
   }
   return nil
}

type ProcessParams struct {
   Topic string
}

func (slf *ProcessParams) HandleMessage(data []byte) (err error) {
   logx.Infof("get an process params message :%s", data)
   var resp = new(common.ResponseProcessParams)
   err = json.Unmarshal(data, &resp)
   if err != nil {
      logx.Errorf("ScheduleTask HandleMessage Unmarshal json err: %v", err.Error())
      return err
   }
   //通知回复收到
   ReceivedMessageChan <- &ReceivedMessage{
      Topic:   slf.Topic,
      Message: data,
   }
   return nil
}