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;
         }

Reply via email to