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 2022/02/08 02:43:59 UTC
[rocketmq] 16/17: change the level to warn when the ack message failed (#3756)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 5d15c3ed170f84bea092ee7d9418dd175cb00487
Author: cserwen <cs...@163.com>
AuthorDate: Sat Jan 15 17:26:38 2022 +0800
change the level to warn when the ack message failed (#3756)
---
.../rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index abe3ca7..87440ff 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
@@ -796,12 +796,12 @@ public class DefaultMQPushConsumerImpl implements MQConsumerInner {
@Override
public void onSuccess(AckResult ackResult) {
if (ackResult != null && !AckStatus.OK.equals(ackResult.getStatus())) {
- log.info("Ack message fail. ackResult: {}, extraInfo: {}", ackResult, extraInfo);
+ log.warn("Ack message fail. ackResult: {}, extraInfo: {}", ackResult, extraInfo);
}
}
@Override
public void onException(Throwable e) {
- log.info("Ack message fail. extraInfo: {} error message: {}", extraInfo, e.toString());
+ log.warn("Ack message fail. extraInfo: {} error message: {}", extraInfo, e.toString());
}
}, requestHeader);