From 79890cb315b8a693c10cb945eeb5ebe73d022187 Mon Sep 17 00:00:00 2001 From: duhengforever Date: Mon, 20 Aug 2018 09:13:09 +0800 Subject: [PATCH] Modify log level --- .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java index d3ecf50d..d095254a 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java @@ -289,7 +289,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { if (transactionCheckListener != null) { localTransactionState = transactionCheckListener.checkLocalTransactionState(message); } else if (transactionListener != null) { - log.info("Used new check API in transaction message"); + log.debug("Used new check API in transaction message"); localTransactionState = transactionListener.checkLocalTransaction(message); } else { log.warn("CheckTransactionState, pick transactionListener by group[{}] failed", group); @@ -1152,7 +1152,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { if (null != localTransactionExecuter) { localTransactionState = localTransactionExecuter.executeLocalTransactionBranch(msg, arg); } else if (transactionListener != null) { - log.info("Used new transaction API"); + log.debug("Used new transaction API"); transactionListener.executeLocalTransaction(msg, arg); } if (null == localTransactionState) { -- GitLab