From 553b01318080a7c14cad76c540b2807a0d714618 Mon Sep 17 00:00:00 2001 From: cc Date: Sat, 14 Dec 2024 21:15:46 +0800 Subject: [PATCH] 1 --- src/main/java/cn/van/business/mq/MessageConsumerService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 6d39c8f..767b807 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -36,7 +36,7 @@ public class MessageConsumerService implements RocketMQListener { // 处理消息 try { rateLimiter.acquire(); // 请求许可。如果超过速率,则此方法会阻塞 - logger.info("消费到消息:{}", jsonObject); + //logger.info("消费到消息:{}", jsonObject); String body = jsonObject.getString("body"); byte[] decodedBody = Base64.getDecoder().decode(body); String decodedBodyStr = new String(decodedBody, StandardCharsets.UTF_8);