From e073403f8a178d75bb6a30c4cec6364b72329ea6 Mon Sep 17 00:00:00 2001 From: xy <748613696@qq.com> Date: Thu, 24 Oct 2024 20:26:45 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B1=8F=E8=94=BD=E6=97=A5=E5=BF=97=EF=BC=8C?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=87=8F=E5=A4=AA=E5=A4=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/middle/rocket/template/RocketMQEnhanceTemplate.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/njcn/middle/rocket/template/RocketMQEnhanceTemplate.java b/src/main/java/com/njcn/middle/rocket/template/RocketMQEnhanceTemplate.java index f5f3033..1363118 100644 --- a/src/main/java/com/njcn/middle/rocket/template/RocketMQEnhanceTemplate.java +++ b/src/main/java/com/njcn/middle/rocket/template/RocketMQEnhanceTemplate.java @@ -68,7 +68,7 @@ public class RocketMQEnhanceTemplate { Message sendMessage = MessageBuilder.withPayload(message).setHeader(RocketMQHeaders.KEYS, message.getKey()).build(); SendResult sendResult = template.syncSend(destination, sendMessage); // 此处为了方便查看给日志转了json,根据选择选择日志记录方式,例如ELK采集 - log.info("[{}]同步消息[{}]发送结果[{}]", destination, JSONObject.toJSON(message), JSONObject.toJSON(sendResult)); + //log.info("[{}]同步消息[{}]发送结果[{}]", destination, JSONObject.toJSON(message), JSONObject.toJSON(sendResult)); return sendResult; }