From 28224ef6dbdeade1468f7babf71cf64d0d1242e1 Mon Sep 17 00:00:00 2001
From: Jack <46790855@qq.com>
Date: Mon, 28 Jul 2025 22:12:42 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E6=81=AF=E9=98=9F=E5=88=97=E5=85=A8?=
 =?UTF-8?q?=E9=83=A8=E5=87=BA=E9=94=99=EF=BC=8C=E6=8E=A5=E6=94=B6=E7=B1=BB?=
 =?UTF-8?q?=E5=9E=8B=EF=BC=8C=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../shop/order/listener/DelayMessageReceiver.java     | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/mall-shop/src/main/java/com/suisung/mall/shop/order/listener/DelayMessageReceiver.java b/mall-shop/src/main/java/com/suisung/mall/shop/order/listener/DelayMessageReceiver.java
index 866b57cb..71e39a00 100644
--- a/mall-shop/src/main/java/com/suisung/mall/shop/order/listener/DelayMessageReceiver.java
+++ b/mall-shop/src/main/java/com/suisung/mall/shop/order/listener/DelayMessageReceiver.java
@@ -23,7 +23,6 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.io.IOException;
-import java.nio.charset.StandardCharsets;
 
 /**
  * 延迟消息接收器，处理过期的消息
@@ -44,11 +43,11 @@ public class DelayMessageReceiver {
     private PushMessageService pushMessageService;
 
     @RabbitListener(queues = MqConstant.DEAD_LETTER_QUEUE_NAME)
-    public void handleExpiredMessage(byte[] data, Channel channel, Message message) {
-        // 将byte[]转换为String，然后调用现有的处理逻辑
-        String dataStr = new String(data, StandardCharsets.UTF_8);
-        handleExpiredMessage(dataStr, channel, message);
-    }
+//    public void handleExpiredMessage(byte[] data, Channel channel, Message message) {
+//        // 将byte[]转换为String，然后调用现有的处理逻辑
+//        String dataStr = new String(data, StandardCharsets.UTF_8);
+//        handleExpiredMessage(dataStr, channel, message);
+//    }
 
     /**
      * 监听死信队列，处理过期的延迟消息