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 <m...@apache.org> 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; }