From 821d2423206eea30a50e27b990a2a73f2566c2dc Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90Li?=
 <15040126243@163.com>
Date: Tue, 4 Jun 2024 13:56:01 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96=20=E5=BB=B6?=
 =?UTF-8?q?=E8=BF=9F=E9=98=9F=E5=88=97=E4=B8=8E=E6=AD=BB=E4=BF=A1=E9=98=9F?=
 =?UTF-8?q?=E5=88=97=E7=9B=91=E5=90=AC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../stream/consumer/ConsumerListener.java      | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java
index b66453ce..c131509f 100644
--- a/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java
+++ b/ruoyi-example/ruoyi-test-mq/src/main/java/org/dromara/stream/consumer/ConsumerListener.java
@@ -25,12 +25,20 @@ public class ConsumerListener {
     }
 
     /**
-     * 处理延迟队列的操作
-     * 该部分处理的延迟操作在消费上的时间可能与设置的TTl不同；
-     * 一般会超长；原因是消息可能并不会按时死亡；可通过延迟队列插件处理
+     * 处理延迟队列消息
      */
-    @RabbitListener(queues = RabbitTtlQueueConfig.DEAD_LETTER_QUEUE)
-    public void receiveMessage(String message){
+    @RabbitListener(queues = RabbitTtlQueueConfig.DELAY_QUEUE_NAME)
+    public void receiveDelayMessage(String message){
         log.info("【消费者】Received delayed message：{}",message);
     }
+
+    /**
+     * 处理死信队列消息
+     * 当消息在延迟队列中未能被正确处理（例如因消费者逻辑错误、超时未ACK等原因）
+     * 它会被自动转发到死信队列中，以便后续的特殊处理或重新尝试。
+     */
+    @RabbitListener(queues = RabbitTtlQueueConfig.DEAD_LETTER_QUEUE)
+    public void receiveDeadMessage(String message){
+        log.info("【消费者】Received dead message：{}",message);
+    }
 }