(rocketmq) branch develop updated: [ISSUE #8241] Remove duplicate code

[jinrongtong]

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 949991e0aa [ISSUE #8241] Remove duplicate code
949991e0aa is described below

commit 949991e0aabb0e05b78a087292a1b4e0f3e969cf
Author: hqbfz <125714719+3424672...@users.noreply.github.com>
AuthorDate: Mon Jun 3 15:38:33 2024 +0800

    [ISSUE #8241] Remove duplicate code
---
 .../apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java | 2 --
 1 file changed, 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 3ac33156b0..3e832e5a9a 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
@@ -581,8 +581,6 @@ public class DefaultMQPushConsumerImpl implements 
MQConsumerInner {
                         
DefaultMQPushConsumerImpl.this.executePopPullRequestImmediately(popRequest);
                         break;
                     case POLLING_FULL:
-                        
DefaultMQPushConsumerImpl.this.executePopPullRequestLater(popRequest, 
pullTimeDelayMillsWhenException);
-                        break;
                     default:
                         
DefaultMQPushConsumerImpl.this.executePopPullRequestLater(popRequest, 
pullTimeDelayMillsWhenException);
                         break;