You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2020/12/23 05:58:54 UTC
[rocketmq-spring] branch master updated: [ISSUE #327] Remove info
log in consumeMessage method
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git
The following commit(s) were added to refs/heads/master by this push:
new 4efcf71 [ISSUE #327] Remove info log in consumeMessage method
4efcf71 is described below
commit 4efcf71fbb51f31255943d9a5b640c1d2030d415
Author: wz2cool <wz...@live.cn>
AuthorDate: Wed Dec 23 13:58:43 2020 +0800
[ISSUE #327] Remove info log in consumeMessage method
---
.../rocketmq/spring/support/DefaultRocketMQListenerContainer.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
index 952b4e1..0b513a3 100644
--- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
+++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
@@ -376,7 +376,7 @@ public class DefaultRocketMQListenerContainer implements InitializingBean,
long now = System.currentTimeMillis();
handleMessage(messageExt);
long costTime = System.currentTimeMillis() - now;
- log.info("consume {} cost: {} ms", messageExt.getMsgId(), costTime);
+ log.debug("consume {} cost: {} ms", messageExt.getMsgId(), costTime);
} catch (Exception e) {
log.warn("consume message failed. messageId:{}, topic:{}, reconsumeTimes:{}", messageExt.getMsgId(), messageExt.getTopic(), messageExt.getReconsumeTimes(), e);
context.setSuspendCurrentQueueTimeMillis(suspendCurrentQueueTimeMillis);
@@ -402,7 +402,7 @@ public class DefaultRocketMQListenerContainer implements InitializingBean,
if (sendResult.getSendStatus() != SendStatus.SEND_OK) {
log.error("Consumer replies message failed. SendStatus: {}", sendResult.getSendStatus());
} else {
- log.info("Consumer replies message success.");
+ log.debug("Consumer replies message success.");
}
}