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 { - //topic_config_manager: TopicConfigManager, - // message_store: ArcMut, - // escape_bridge: ArcMut>, - // store_host: SocketAddr, - //pop_inflight_message_counter: Arc, - // consumer_offset_manager: Arc, - // consumer_order_info_manager: Arc>, pop_message_processor: ArcMut>, broker_runtime_inner: ArcMut>, } @@ -70,28 +63,11 @@ where MS: MessageStore, { pub fn new( - /*topic_config_manager: TopicConfigManager, - message_store: ArcMut, - escape_bridge: ArcMut>, - broker_config: Arc, - pop_inflight_message_counter: Arc, - store_host: SocketAddr, - consumer_offset_manager: Arc, - pop_message_processor: ArcMut>, - consumer_order_info_manager: Arc>,*/ - //pop_inflight_message_counter: Arc, broker_runtime_inner: ArcMut>, pop_message_processor: ArcMut>, ) -> AckMessageProcessor { 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, } }