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/10/10 01:42:05 UTC
[pulsar] branch master updated: [cleanup][broker]remove methods no longer used in AdminResource #7 (#17969)
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 ca648b244e9 [cleanup][broker]remove methods no longer used in AdminResource #7 (#17969)
ca648b244e9 is described below
commit ca648b244e9e3ffedf42a28bfb8007f2bd50fc15
Author: HuangZeGui <hz...@126.com>
AuthorDate: Mon Oct 10 09:41:56 2022 +0800
[cleanup][broker]remove methods no longer used in AdminResource #7 (#17969)
---
.../apache/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 bab7ed05424..645c804af2f 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 javax.ws.rs.core.Response.Status;
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 @@ public abstract class AdminResource extends PulsarWebResource {
});
}
- 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()) {