@@ -47,24 +47,7 @@ pub struct AdminBrokerProcessor<MS> {
4747}
4848
4949impl < MS : MessageStore > AdminBrokerProcessor < MS > {
50- pub fn new (
51- /* broker_config: Arc<BrokerConfig>,
52- server_config: Arc<ServerConfig>,
53- message_store_config: Arc<MessageStoreConfig>,
54- topic_config_manager: TopicConfigManager,
55- consumer_offset_manager: ConsumerOffsetManager,
56- topic_queue_mapping_manager: Arc<TopicQueueMappingManager>,
57- default_message_store: ArcMut<DefaultMessageStore>,
58- schedule_message_service: ScheduleMessageService,
59- broker_stats: Option<Arc<BrokerStats<DefaultMessageStore>>>,
60- consume_manager: Arc<ConsumerManager>,
61- broker_out_api: Arc<BrokerOuterAPI>,
62- broker_stats_manager: Arc<BrokerStatsManager>,
63- rebalance_lock_manager: Arc<RebalanceLockManager>,
64- broker_member_group: Arc<BrokerMemberGroup>,
65- pop_inflight_message_counter: Arc<PopInflightMessageCounter>,*/
66- broker_runtime_inner : ArcMut < BrokerRuntimeInner < MS > > ,
67- ) -> Self {
50+ pub fn new ( broker_runtime_inner : ArcMut < BrokerRuntimeInner < MS > > ) -> Self {
6851 let topic_request_handler = TopicRequestHandler :: new ( broker_runtime_inner. clone ( ) ) ;
6952 let broker_config_request_handler =
7053 BrokerConfigRequestHandler :: new ( broker_runtime_inner. clone ( ) ) ;
0 commit comments