From 92516d081cdf08673dc369981b99ebcee517e2be Mon Sep 17 00:00:00 2001 From: zpl Date: Fri, 16 Jul 2021 09:13:35 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=BE=E5=A4=87=E6=8E=A5=E5=8F=A3=E7=9A=84?= =?UTF-8?q?=E5=8A=9F=E8=83=BD=E5=AE=8C=E5=96=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../foreverwin/mesnac/equip/consumer/ResourceMQConsume.java | 4 ++-- .../equip/service/impl/ResourceRepairTaskServiceImpl.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) 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));