This is an automated email from the ASF dual-hosted git repository. zhangyang pushed a commit to branch 5.0.0-alpha in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 6928c5d349f873f5e274f44135326c9c493b8182 Author: hill007299 <hill007...@126.com> AuthorDate: Tue Mar 9 11:21:48 2021 +0800 [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 --- .../src/main/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 bfac860..0207465 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());