1

src/main/java/cn/van/business/mq/MessageConsumerService.java

@@ -28,6 +28,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
     public void onMessage(JSONObject jsonObject) {
         // 处理消息
         try {
+            logger.info("消费到消息：{}", jsonObject);
             String responseStr = HttpRequest.post(WX_BASE_URL)
                     .body(JSONUtil.toJsonStr(jsonObject))
                     .execute()