You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2021/12/20 10:46:09 UTC
[rocketmq] branch develop updated: [ISSUE #1486] fix CleanUnusedTopicCommand performs wrong (#1487)
This is an automated email from the ASF dual-hosted git repository.
yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 7591227 [ISSUE #1486] fix CleanUnusedTopicCommand performs wrong (#1487)
7591227 is described below
commit 7591227a8364f7a731f5e4e79d81a04313ddc51e
Author: ChaosYjh <76...@qq.com>
AuthorDate: Mon Dec 20 18:45:48 2021 +0800
[ISSUE #1486] fix CleanUnusedTopicCommand performs wrong (#1487)
Co-authored-by: yuanjunhui <yu...@qq.com>
---
.../main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java | 2 +-
.../apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
index c3e3a30..3ffe33f 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
@@ -424,7 +424,7 @@ public class DefaultMQAdminExt extends ClientConfig implements MQAdminExt {
@Override
public boolean cleanUnusedTopic(String cluster) throws RemotingConnectException, RemotingSendRequestException,
RemotingTimeoutException, MQClientException, InterruptedException {
- return defaultMQAdminExtImpl.cleanUnusedTopicByAddr(cluster);
+ return defaultMQAdminExtImpl.cleanUnusedTopic(cluster);
}
@Override
diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java
index 2aabeeb..045ba8e 100644
--- a/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java
+++ b/tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java
@@ -66,7 +66,7 @@ public class CleanUnusedTopicCommand implements SubCommand {
String cluster = commandLine.getOptionValue('c');
if (null != cluster)
cluster = cluster.trim();
- result = defaultMQAdminExt.cleanUnusedTopicByAddr(cluster);
+ result = defaultMQAdminExt.cleanUnusedTopic(cluster);
}
System.out.printf(result ? "success" : "false");
} catch (Exception e) {