From ca648b244e9e3ffedf42a28bfb8007f2bd50fc15 Mon Sep 17 00:00:00 2001 From: HuangZeGui Date: Mon, 10 Oct 2022 09:41:56 +0800 Subject: [PATCH] [cleanup][broker]remove methods no longer used in AdminResource #7 (#17969) --- .../pulsar/broker/admin/AdminResource.java | 25 ------------------- 1 file changed, 25 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java index bab7ed0542402..645c804af2f8e 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java @@ -38,7 +38,6 @@ import lombok.extern.slf4j.Slf4j; import org.apache.bookkeeper.client.BookKeeper; import org.apache.bookkeeper.mledger.ManagedLedgerException; -import org.apache.pulsar.broker.PulsarService; import org.apache.pulsar.broker.ServiceConfiguration; import org.apache.pulsar.broker.web.PulsarWebResource; import org.apache.pulsar.broker.web.RestException; @@ -481,30 +480,6 @@ protected CompletableFuture getPartitionedTopicMetadat }); } - protected static PartitionedTopicMetadata fetchPartitionedTopicMetadata(PulsarService pulsar, TopicName topicName) { - try { - return pulsar.getBrokerService().fetchPartitionedTopicMetadataAsync(topicName).get(); - } catch (Exception e) { - if (e.getCause() instanceof RestException) { - throw (RestException) e.getCause(); - } - throw new RestException(e); - } - } - - protected static PartitionedTopicMetadata fetchPartitionedTopicMetadataCheckAllowAutoCreation( - PulsarService pulsar, TopicName topicName) { - try { - return pulsar.getBrokerService().fetchPartitionedTopicMetadataCheckAllowAutoCreationAsync(topicName) - .get(); - } catch (Exception e) { - if (e.getCause() instanceof RestException) { - throw (RestException) e.getCause(); - } - throw new RestException(e); - } - } - protected void validateClusterExists(String cluster) { try { if (!clusterResources().getCluster(cluster).isPresent()) {