| | |
| | | boolean offer = false; |
| | | try { |
| | | offer = MessageQueue.offer(SlaveType.Devp, 1, new Task(2, staProtocol)); |
| | | if(taskWrk.getMp() == 1) { |
| | | staProtocol.setMp(taskWrk.getMp()); |
| | | staProtocol.setLx(taskWrk.getLx()); |
| | | staProtocol.setLev(taskWrk.getLev()); |
| | | MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); |
| | | } |
| | | staProtocol.setMp(taskWrk.getMp()); |
| | | staProtocol.setLx(taskWrk.getLx()); |
| | | staProtocol.setLev(taskWrk.getLev()); |
| | | MessageQueue.offer(SlaveType.Devp, 1, new Task(3, staProtocol)); |
| | | } catch (Exception e) { |
| | | log.error("下发输送线任务失败:异常:" + e); |
| | | log.error("下发输送线任务失败:异常:offer:" + offer); |