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