|
@@ -37,18 +37,18 @@ public class JmsConfig {
|
|
|
@Value("${persagy.dmp.alarm.queue}")
|
|
|
private String alarmQueue;
|
|
|
|
|
|
- @Value("${persagy.dmp.alarm.rwd.queue}")
|
|
|
- private String alarmRwdQueue;
|
|
|
-
|
|
|
- @Bean
|
|
|
- public Queue alarmRwdQueue() {
|
|
|
- return new Queue(alarmRwdQueue, true);
|
|
|
- }
|
|
|
-
|
|
|
- @Bean
|
|
|
- public Binding alarmRwdBinding() {
|
|
|
- return BindingBuilder.bind(alarmRwdQueue()).to(exchange()).with(rwdRoutingKey);
|
|
|
- }
|
|
|
+// @Value("${persagy.dmp.alarm.rwd.queue}")
|
|
|
+// private String alarmRwdQueue;
|
|
|
+//
|
|
|
+// @Bean
|
|
|
+// public Queue alarmRwdQueue() {
|
|
|
+// return new Queue(alarmRwdQueue, true);
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Bean
|
|
|
+// public Binding alarmRwdBinding() {
|
|
|
+// return BindingBuilder.bind(alarmRwdQueue()).to(exchange()).with(rwdRoutingKey);
|
|
|
+// }
|
|
|
|
|
|
/**
|
|
|
* 报警对象队列
|
|
@@ -109,10 +109,10 @@ public class JmsConfig {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- @RabbitListener(queues ="${persagy.dmp.alarm.rwd.queue}") //监听器监听指定的Queue
|
|
|
- public void processRwdMsg(DmpMessage message, Channel channel, Message msg) {
|
|
|
- consumeMessageThreadPool.consumeMessage(message, channel, msg);
|
|
|
- }
|
|
|
+// @RabbitListener(queues ="${persagy.dmp.alarm.rwd.queue}") //监听器监听指定的Queue
|
|
|
+// public void processRwdMsg(DmpMessage message, Channel channel, Message msg) {
|
|
|
+// consumeMessageThreadPool.consumeMessage(message, channel, msg);
|
|
|
+// }
|
|
|
|
|
|
@RabbitListener(queues = "${persagy.dmp.alarm.queue}") //监听器监听指定的Queue
|
|
|
public void processAlarmMsg(DmpMessage message, Channel channel, Message msg) {
|