From 3de9b89993565372eb5d9ab509d5c1c5a305b967 Mon Sep 17 00:00:00 2001
From: mxsm <mxsm@apache.org>
Date: Sat, 25 Jan 2025 16:02:56 +0800
Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2408]=F0=9F=A4=A1Remove=20AckMessageP?=
 =?UTF-8?q?rocessor=20useless=20code=F0=9F=A7=91=E2=80=8D=F0=9F=92=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/processor/ack_message_processor.rs    | 24 -------------------
 1 file changed, 24 deletions(-)

diff --git a/rocketmq-broker/src/processor/ack_message_processor.rs b/rocketmq-broker/src/processor/ack_message_processor.rs
index 65a09545..e7bbaea7 100644
--- a/rocketmq-broker/src/processor/ack_message_processor.rs
+++ b/rocketmq-broker/src/processor/ack_message_processor.rs
@@ -54,13 +54,6 @@ use crate::broker_runtime::BrokerRuntimeInner;
 use crate::processor::pop_message_processor::PopMessageProcessor;
 
 pub struct AckMessageProcessor<MS> {
-    //topic_config_manager: TopicConfigManager,
-    // message_store: ArcMut<MS>,
-    // escape_bridge: ArcMut<EscapeBridge<MS>>,
-    //  store_host: SocketAddr,
-    //pop_inflight_message_counter: Arc<PopInflightMessageCounter>,
-    //  consumer_offset_manager: Arc<ConsumerOffsetManager>,
-    //   consumer_order_info_manager: Arc<ConsumerOrderInfoManager<MS>>,
     pop_message_processor: ArcMut<PopMessageProcessor<MS>>,
     broker_runtime_inner: ArcMut<BrokerRuntimeInner<MS>>,
 }
@@ -70,28 +63,11 @@ where
     MS: MessageStore,
 {
     pub fn new(
-        /*topic_config_manager: TopicConfigManager,
-        message_store: ArcMut<MS>,
-        escape_bridge: ArcMut<EscapeBridge<MS>>,
-        broker_config: Arc<BrokerConfig>,
-        pop_inflight_message_counter: Arc<PopInflightMessageCounter>,
-        store_host: SocketAddr,
-        consumer_offset_manager: Arc<ConsumerOffsetManager>,
-        pop_message_processor: ArcMut<PopMessageProcessor<MS>>,
-        consumer_order_info_manager: Arc<ConsumerOrderInfoManager<MS>>,*/
-        //pop_inflight_message_counter: Arc<PopInflightMessageCounter>,
         broker_runtime_inner: ArcMut<BrokerRuntimeInner<MS>>,
         pop_message_processor: ArcMut<PopMessageProcessor<MS>>,
     ) -> AckMessageProcessor<MS> {
         AckMessageProcessor {
-            /*  topic_config_manager,
-             message_store,
-             escape_bridge,
-             store_host,*/
-            // pop_inflight_message_counter,
-             /* consumer_offset_manager, */
             pop_message_processor,
-            /* consumer_order_info_manager, */
             broker_runtime_inner,
         }
     }