diff --git a/rocketmq-broker/src/filter/manager/consumer_filter_manager.rs b/rocketmq-broker/src/filter/manager/consumer_filter_manager.rs index b71b0879..d9e8aace 100644 --- a/rocketmq-broker/src/filter/manager/consumer_filter_manager.rs +++ b/rocketmq-broker/src/filter/manager/consumer_filter_manager.rs @@ -32,7 +32,7 @@ impl ConfigManager for ConsumerFilterManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String { diff --git a/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs b/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs index f63c8255..c3769a60 100644 --- a/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs +++ b/rocketmq-broker/src/offset/manager/consumer_offset_manager.rs @@ -32,7 +32,7 @@ impl ConfigManager for ConsumerOffsetManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String { diff --git a/rocketmq-broker/src/offset/manager/consumer_order_info_manager.rs b/rocketmq-broker/src/offset/manager/consumer_order_info_manager.rs index d29b436d..15cb5085 100644 --- a/rocketmq-broker/src/offset/manager/consumer_order_info_manager.rs +++ b/rocketmq-broker/src/offset/manager/consumer_order_info_manager.rs @@ -32,7 +32,7 @@ impl ConfigManager for ConsumerOrderInfoManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String { diff --git a/rocketmq-broker/src/subscription/manager/subscription_group_manager.rs b/rocketmq-broker/src/subscription/manager/subscription_group_manager.rs index 0494e692..5b2315a0 100644 --- a/rocketmq-broker/src/subscription/manager/subscription_group_manager.rs +++ b/rocketmq-broker/src/subscription/manager/subscription_group_manager.rs @@ -32,7 +32,7 @@ impl ConfigManager for SubscriptionGroupManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String { diff --git a/rocketmq-broker/src/topic/manager/topic_config_manager.rs b/rocketmq-broker/src/topic/manager/topic_config_manager.rs index 8a6304c3..7f86492c 100644 --- a/rocketmq-broker/src/topic/manager/topic_config_manager.rs +++ b/rocketmq-broker/src/topic/manager/topic_config_manager.rs @@ -34,7 +34,7 @@ impl ConfigManager for TopicConfigManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String { diff --git a/rocketmq-broker/src/topic/manager/topic_queue_mapping_manager.rs b/rocketmq-broker/src/topic/manager/topic_queue_mapping_manager.rs index 98aeff12..c4361a39 100644 --- a/rocketmq-broker/src/topic/manager/topic_queue_mapping_manager.rs +++ b/rocketmq-broker/src/topic/manager/topic_queue_mapping_manager.rs @@ -32,7 +32,7 @@ impl ConfigManager for TopicQueueMappingManager { } fn config_file_path(&mut self) -> &str { - todo!() + "" } fn encode(&mut self) -> String {