From eb02d7f82573b34929cc8f37c84986274f3e8b44 Mon Sep 17 00:00:00 2001 From: Leo Date: Sun, 1 Dec 2024 15:26:25 +0800 Subject: [PATCH] 1 --- src/main/java/cn/van/business/mq/MessageConsumerService.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 695bd8b..e4d322b 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -28,6 +28,7 @@ public class MessageConsumerService implements RocketMQListener { public void onMessage(JSONObject jsonObject) { // 处理消息 try { + logger.info("消费到消息:{}", jsonObject); String responseStr = HttpRequest.post(WX_BASE_URL) .body(JSONUtil.toJsonStr(jsonObject)) .execute()