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 65a049c2..bdc1e4b3 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 @@ -49,7 +49,7 @@ public class ResourceMQConsume { // template.convertAndSend((Queue) headers.get("jms_replyTo"), resultString); } - @JmsListener(destination = "resource.edc.process", containerFactory = "defaultFactory", concurrency = "5") + @JmsListener(destination = "resource.parameter.process", containerFactory = "defaultFactory", concurrency = "5") public void resourceEdcProcess(String text) { logger.info("接收设备参数数据:" + text); resourceMQProcess.resourceParamProcess(text);