|
|
|
@ -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")
|
|
|
|
|