From 6ba93446b3a2fb6763632fc16aef47c2af14768a Mon Sep 17 00:00:00 2001 From: hill007299 Date: Tue, 9 Mar 2021 11:21:48 +0800 Subject: [PATCH] [RIP-19] Pop Consuming (tools) Conflicts: tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java --- .../java/org/apache/rocketmq/tools/command/MQAdminStartup.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java index bfac860d08..02074658ae 100644 --- a/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java +++ b/tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java @@ -48,6 +48,7 @@ import org.apache.rocketmq.tools.command.consumer.ConsumerProgressSubCommand; import org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand; import org.apache.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand; import org.apache.rocketmq.tools.command.consumer.GetConsumerConfigSubCommand; +import org.apache.rocketmq.tools.command.consumer.SetConsumeModeSubCommand; import org.apache.rocketmq.tools.command.consumer.StartMonitoringSubCommand; import org.apache.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand; import org.apache.rocketmq.tools.command.export.ExportConfigsCommand; @@ -160,6 +161,7 @@ public class MQAdminStartup { initCommand(new UpdateTopicSubCommand()); initCommand(new DeleteTopicSubCommand()); initCommand(new UpdateSubGroupSubCommand()); + initCommand(new SetConsumeModeSubCommand()); initCommand(new DeleteSubscriptionGroupCommand()); initCommand(new UpdateBrokerConfigSubCommand()); initCommand(new UpdateTopicPermSubCommand());