opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Rename cleanBrokerData subCommand to cleanBrokerMetadata

Browse Source
This commit is contained in:
RongtongJin
2023-03-14 09:40:15 +08:00
committed by rongtong
parent 28618e95ab
commit c8bc4e84a0
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
+2 -2
View File
@@ -55,7 +55,7 @@ import org.apache.rocketmq.tools.command.consumer.StartMonitoringSubCommand;
import org.apache.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand;
import org.apache.rocketmq.tools.command.container.AddBrokerSubCommand;
import org.apache.rocketmq.tools.command.container.RemoveBrokerSubCommand;
import org.apache.rocketmq.tools.command.controller.CleanControllerBrokerDataSubCommand;
import org.apache.rocketmq.tools.command.controller.CleanControllerBrokerMetaSubCommand;
import org.apache.rocketmq.tools.command.controller.GetControllerConfigSubCommand;
import org.apache.rocketmq.tools.command.controller.GetControllerMetaDataSubCommand;
import org.apache.rocketmq.tools.command.controller.ReElectMasterSubCommand;
@@ -261,7 +261,7 @@ public class MQAdminStartup {
initCommand(new GetControllerConfigSubCommand());
initCommand(new UpdateControllerConfigSubCommand());
initCommand(new ReElectMasterSubCommand());
initCommand(new CleanControllerBrokerDataSubCommand());
initCommand(new CleanControllerBrokerMetaSubCommand());
initCommand(new DumpCompactionLogCommand());
}
tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerDataSubCommand.java → tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java
+4 -4
View File
@@ -26,16 +26,16 @@ import org.apache.rocketmq.tools.admin.DefaultMQAdminExt;
import org.apache.rocketmq.tools.command.SubCommand;
import org.apache.rocketmq.tools.command.SubCommandException;
public class CleanControllerBrokerDataSubCommand implements SubCommand {
public class CleanControllerBrokerMetaSubCommand implements SubCommand {
@Override
public String commandName() {
return "cleanBrokerData";
return "cleanBrokerMetadata";
}
@Override
public String commandDesc() {
return "Clean data of broker on controller";
return "Clean metadata of broker on controller";
}
@Override
@@ -93,7 +93,7 @@ public class CleanControllerBrokerDataSubCommand implements SubCommand {
try {
defaultMQAdminExt.start();
defaultMQAdminExt.cleanControllerBrokerData(controllerAddress, clusterName, brokerName, brokerAddress, isCleanLivingBroker);
System.out.printf("clear broker %s data from controller success! \n", brokerName);
System.out.printf("clear broker %s metadata from controller success! \n", brokerName);
} catch (Exception e) {
throw new SubCommandException(this.getClass().getSimpleName() + " command failed", e);
} finally {