From e2b0c72d682a24a6b9c632e584a5d2b3a08a78ee Mon Sep 17 00:00:00 2001
From: mxsm <mxsm@apache.org>
Date: Mon, 23 Dec 2024 08:09:36 +0000
Subject: [PATCH] [ISSUE #1925] Implement
 DefaultMQAdminExt#setMessageRequestMode

---
 rocketmq-tools/src/admin/default_mq_admin_ext.rs | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/rocketmq-tools/src/admin/default_mq_admin_ext.rs b/rocketmq-tools/src/admin/default_mq_admin_ext.rs
index b3c8ad01..67739893 100644
--- a/rocketmq-tools/src/admin/default_mq_admin_ext.rs
+++ b/rocketmq-tools/src/admin/default_mq_admin_ext.rs
@@ -526,7 +526,16 @@ impl MQAdminExt for DefaultMQAdminExt {
         pop_work_group_size: i32,
         timeout_millis: u64,
     ) -> crate::Result<()> {
-        todo!()
+        self.default_mqadmin_ext_impl
+            .set_message_request_mode(
+                broker_addr,
+                topic,
+                consumer_group,
+                mode,
+                pop_work_group_size,
+                timeout_millis,
+            )
+            .await
     }
 
     async fn reset_offset_by_queue_id(