opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

change the level to warn when the ack message failed (#3756)

Browse Source
This commit is contained in:
cserwen
2022-02-08 10:38:41 +08:00
committed by RongtongJin
parent fe88fb36a3
commit 5d15c3ed17
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+2 -2
View File
@@ -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);