[rocketmq] branch develop updated: [ISSUE #1486] fix CleanUnusedTopicCommand performs wrong (#1487)

[yuzhou]

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 <763900...@qq.com>
AuthorDate: Mon Dec 20 18:45:48 2021 +0800

    [ISSUE #1486] fix CleanUnusedTopicCommand performs wrong (#1487)
    
    Co-authored-by: yuanjunhui <yuanjunhui1...@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) {