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); +// } /** * 监听死信队列,处理过期的延迟消息