diff --git a/rocketmq-broker/src/processor/admin_broker_processor.rs b/rocketmq-broker/src/processor/admin_broker_processor.rs index 2a0d9ef7b..860b353f3 100644 --- a/rocketmq-broker/src/processor/admin_broker_processor.rs +++ b/rocketmq-broker/src/processor/admin_broker_processor.rs @@ -47,24 +47,7 @@ pub struct AdminBrokerProcessor { } impl AdminBrokerProcessor { - pub fn new( - /* broker_config: Arc, - server_config: Arc, - message_store_config: Arc, - topic_config_manager: TopicConfigManager, - consumer_offset_manager: ConsumerOffsetManager, - topic_queue_mapping_manager: Arc, - default_message_store: ArcMut, - schedule_message_service: ScheduleMessageService, - broker_stats: Option>>, - consume_manager: Arc, - broker_out_api: Arc, - broker_stats_manager: Arc, - rebalance_lock_manager: Arc, - broker_member_group: Arc, - pop_inflight_message_counter: Arc,*/ - broker_runtime_inner: ArcMut>, - ) -> Self { + pub fn new(broker_runtime_inner: ArcMut>) -> Self { let topic_request_handler = TopicRequestHandler::new(broker_runtime_inner.clone()); let broker_config_request_handler = BrokerConfigRequestHandler::new(broker_runtime_inner.clone());