This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 349e4dababe35d5fbd12caa7d1c6f8bdad3d44e5 Author: chenlin <[email protected]> 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 (cherry picked from commit bef306c764aaff0e156ebfd2c7a99c9dc1ad8dd1) --- .../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 c4bea81..31aae39 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,
