This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 93e268909c [ISSUE #9054] Optimize log print when client consume
message in pop mode (#9055)
93e268909c is described below
commit 93e268909cb92dd6d4033a4a36e1daab40025a75
Author: mxsm <[email protected]>
AuthorDate: Sun Dec 15 10:34:08 2024 +0800
[ISSUE #9054] Optimize log print when client consume message in pop mode
(#9055)
---
.../apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 46715cea95..c93cff4245 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
@@ -510,7 +510,7 @@ public class DefaultMQPushConsumerImpl implements
MQConsumerInner {
try {
this.makeSureStateOK();
} catch (MQClientException e) {
- log.warn("pullMessage exception, consumer state not ok", e);
+ log.warn("popMessage exception, consumer state not ok", e);
this.executePopPullRequestLater(popRequest,
pullTimeDelayMillsWhenException);
return;
}