暂时注释掉对物理世界消息队列的监听

dmp-alarm/src/main/java/com/persagy/dmp/alarm/jms/JmsConfig.java

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