[pulsar] branch master updated: remove redundant parameters (#12188)

[aahmed]

This is an automated email from the ASF dual-hosted git repository.

aahmed pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new bef306c  remove redundant parameters (#12188)
bef306c is described below

commit bef306c764aaff0e156ebfd2c7a99c9dc1ad8dd1
Author: chenlin <1572139...@qq.com>
AuthorDate: Thu Sep 30 04:21:37 2021 +0800

    remove redundant parameters (#12188)
    
    * In the method internalConsumerFlow, the parameter 
additionalNumberOfMessages is redundant
    
    * Trigger CICD
    
    * Trigger CICD
---
 .../service/persistent/PersistentDispatcherSingleActiveConsumer.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java
index 3c22242..fa7ac03 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java
@@ -247,11 +247,11 @@ public class PersistentDispatcherSingleActiveConsumer 
extends AbstractDispatcher
     @Override
     public void consumerFlow(Consumer consumer, int 
additionalNumberOfMessages) {
         
topic.getBrokerService().getTopicOrderedExecutor().executeOrdered(topicName, 
SafeRun.safeRun(() -> {
-            internalConsumerFlow(consumer, additionalNumberOfMessages);
+            internalConsumerFlow(consumer);
         }));
     }
 
-    private synchronized void internalConsumerFlow(Consumer consumer, int 
additionalNumberOfMessages) {
+    private synchronized void internalConsumerFlow(Consumer consumer) {
         if (havePendingRead) {
             if (log.isDebugEnabled()) {
                 log.debug("[{}-{}] Ignoring flow control message since we 
already have a pending read req", name,