You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/01/15 09:26:51 UTC
[rocketmq] branch 5.0.0-alpha updated: change the level to warn when the ack message failed (#3756)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/5.0.0-alpha by this push:
new 1b09702 change the level to warn when the ack message failed (#3756)
1b09702 is described below
commit 1b097024a755b696c3cca667993cbcea29a2a4b9
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);