瀏覽代碼

处理报警和rwd的入口分开

lgy 3 年之前
父節點
當前提交
da81fff036

+ 1 - 0
dmp-alarm/src/main/java/com/persagy/dmp/alarm/jms/ConsumeMessageThreadPool.java

@@ -44,6 +44,7 @@ public class ConsumeMessageThreadPool {
                 // 手动确认消息已消费
                 channel.basicAck(msg.getMessageProperties().getDeliveryTag(), false);
             } catch (Exception e) {
+                log.error(e.getMessage(),e);
                 Boolean isRedeliveredFail = msg.getMessageProperties().getRedelivered();
                 // true表示消息已经重复处理失败
                 try {

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

@@ -109,8 +109,13 @@ public class JmsConfig {
         }
     }
 
-    @RabbitListener(queues = {"${persagy.dmp.alarm.queue}", "${persagy.dmp.alarm.rwd.queue}"})    //监听器监听指定的Queue
-    public void process(DmpMessage message, Channel channel, Message 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) {
         consumeMessageThreadPool.consumeMessage(message, channel, msg);
     }
 }