You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/05/02 02:44:37 UTC
[pulsar] branch master updated: Clean unsed methods in BrokerService (#15257)
This is an automated email from the ASF dual-hosted git repository.
technoboy 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 cd6dfee6ea7 Clean unsed methods in BrokerService (#15257)
cd6dfee6ea7 is described below
commit cd6dfee6ea74ae57bac689702038d8f6964855ca
Author: Xiaoyu Hou <An...@gmail.com>
AuthorDate: Mon May 2 10:44:28 2022 +0800
Clean unsed methods in BrokerService (#15257)
---
.../org/apache/pulsar/broker/service/BrokerService.java | 14 --------------
1 file changed, 14 deletions(-)
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index 5d988330e6a..6a8892c646d 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -1160,11 +1160,6 @@ public class BrokerService implements Closeable {
return topicFuture;
}
- private <T> CompletableFuture<T> futureWithDeadline() {
- return FutureUtil.createFutureWithTimeout(FUTURE_DEADLINE_TIMEOUT_DURATION, executor(),
- () -> FUTURE_DEADLINE_TIMEOUT_EXCEPTION);
- }
-
public PulsarClient getReplicationClient(String cluster, Optional<ClusterData> clusterDataOp) {
PulsarClient client = replicationClients.get(cluster);
if (client != null) {
@@ -2822,15 +2817,6 @@ public class BrokerService implements Closeable {
}
}
- private void foreachCnx(Consumer<TransportCnx> consumer) {
- Set<TransportCnx> cnxSet = new HashSet<>();
- topics.forEach((n, t) -> {
- Optional<Topic> topic = extractTopic(t);
- topic.ifPresent(value -> value.getProducers().values().forEach(producer -> cnxSet.add(producer.getCnx())));
- });
- cnxSet.forEach(consumer);
- }
-
public boolean isAllowAutoTopicCreation(final String topic) {
TopicName topicName = TopicName.get(topic);
return isAllowAutoTopicCreation(topicName);