You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/10/06 05:12:46 UTC
[pulsar] 03/12: remove redundant parameters (#12188)
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 <15...@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
(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,