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 2022/05/18 00:44:46 UTC
[pulsar] branch master updated: [cleanup] [broker] Delete duplicate method definitions (#15613)
This is an automated email from the ASF dual-hosted git repository.
penghui 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 10e4a48b5d8 [cleanup] [broker] Delete duplicate method definitions (#15613)
10e4a48b5d8 is described below
commit 10e4a48b5d83e7a426f47376a26e39b5dad059f5
Author: fengyubiao <99...@qq.com>
AuthorDate: Wed May 18 08:44:41 2022 +0800
[cleanup] [broker] Delete duplicate method definitions (#15613)
---
.../nonpersistent/NonPersistentDispatcher.java | 21 ---------------------
1 file changed, 21 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.java
index 1ef2db25613..818a249ed7e 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcher.java
@@ -19,36 +19,15 @@
package org.apache.pulsar.broker.service.nonpersistent;
import java.util.List;
-import java.util.concurrent.CompletableFuture;
import org.apache.bookkeeper.mledger.Entry;
import org.apache.bookkeeper.mledger.impl.PositionImpl;
-import org.apache.pulsar.broker.service.BrokerServiceException;
import org.apache.pulsar.broker.service.Consumer;
import org.apache.pulsar.broker.service.Dispatcher;
-import org.apache.pulsar.common.api.proto.CommandSubscribe.SubType;
import org.apache.pulsar.common.stats.Rate;
public interface NonPersistentDispatcher extends Dispatcher {
- void addConsumer(Consumer consumer) throws BrokerServiceException;
-
- void removeConsumer(Consumer consumer) throws BrokerServiceException;
-
- boolean isConsumerConnected();
-
- List<Consumer> getConsumers();
-
- boolean canUnsubscribe(Consumer consumer);
-
- CompletableFuture<Void> close();
-
- CompletableFuture<Void> disconnectAllConsumers(boolean isResetCursor);
-
- void reset();
-
- SubType getType();
-
void sendMessages(List<Entry> entries);
Rate getMessageDropRate();