You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/02/08 02:43:46 UTC
[rocketmq] 03/17: [RIP-19] Pop Consuming (tools)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 6ba93446b3a2fb6763632fc16aef47c2af14768a
Author: hill007299 <hi...@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());