屏蔽日志,数据量太大
This commit is contained in:
@@ -68,7 +68,7 @@ public class RocketMQEnhanceTemplate {
|
||||
Message<T> 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;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user