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()