You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by aa...@apache.org on 2021/09/29 20:22:32 UTC
[pulsar] branch master updated: remove redundant parameters (#12188)
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 <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
---
.../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,