diff --git a/equip/src/main/java/com/foreverwin/mesnac/equip/consumer/ResourceMQConsume.java b/equip/src/main/java/com/foreverwin/mesnac/equip/consumer/ResourceMQConsume.java index 1f23cb1a..33444777 100644 --- a/equip/src/main/java/com/foreverwin/mesnac/equip/consumer/ResourceMQConsume.java +++ b/equip/src/main/java/com/foreverwin/mesnac/equip/consumer/ResourceMQConsume.java @@ -39,14 +39,14 @@ public class ResourceMQConsume { String resultString = resourceMQProcess.resourceStatusProcess(text); //返回设备处理结果 - template.convertAndSend((Queue) headers.get("jms_replyTo"), resultString); +// template.convertAndSend((Queue) headers.get("jms_replyTo"), resultString); } @JmsListener(destination = "resource.alarm.process", containerFactory = "defaultFactory") public void resourceAlarmProcess(String text, MessageHeaders headers) { logger.info("接收设备报警数据:" + text); String resultString = resourceMQProcess.resourceFaultProcess(text); - template.convertAndSend((Queue) headers.get("jms_replyTo"), resultString); +// template.convertAndSend((Queue) headers.get("jms_replyTo"), resultString); } @JmsListener(destination = "resource.edc.process", containerFactory = "defaultFactory", concurrency = "5") diff --git a/equip/src/main/java/com/foreverwin/mesnac/equip/service/impl/ResourceRepairTaskServiceImpl.java b/equip/src/main/java/com/foreverwin/mesnac/equip/service/impl/ResourceRepairTaskServiceImpl.java index db82dade..95d6afa3 100644 --- a/equip/src/main/java/com/foreverwin/mesnac/equip/service/impl/ResourceRepairTaskServiceImpl.java +++ b/equip/src/main/java/com/foreverwin/mesnac/equip/service/impl/ResourceRepairTaskServiceImpl.java @@ -81,11 +81,11 @@ public class ResourceRepairTaskServiceImpl extends ServiceImpl nextNumber = nextNumberHelper.getNextNumber(site, Constants.RESOURCE_REPAIR_TASK, 1); resourceRepairTask.setRepairNo(nextNumber.get(0));