[ISSUE #2265]🚀ScheduleMessageService and TopicRouteInfoManager add sh…

…utdown method (#2266)
mxsm · Jan 15, 2025 · ede63cc · ede63cc
1 parent 181be4d
commit ede63cc
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/rocketmq-broker/src/schedule/schedule_message_service.rs b/rocketmq-broker/src/schedule/schedule_message_service.rs
@@ -21,6 +21,7 @@ use std::sync::Arc;
 use rocketmq_common::common::broker::broker_config::BrokerConfig;
 use rocketmq_common::common::config_manager::ConfigManager;
 use rocketmq_store::store_path_config_helper::get_delay_offset_store_path;
+use tracing::warn;
 
 #[derive(Default, Clone)]
 pub struct ScheduleMessageService {
@@ -39,6 +40,10 @@ impl ScheduleMessageService {
     pub fn get_max_delay_level(&self) -> i32 {
         0
     }
+
+    pub fn shutdown(&mut self) {
+        warn!("ScheduleMessageService shutdown not implemented");
+    }
 }
 
 impl ConfigManager for ScheduleMessageService {

diff --git a/rocketmq-broker/src/topic/manager/topic_route_info_manager.rs b/rocketmq-broker/src/topic/manager/topic_route_info_manager.rs
@@ -89,6 +89,9 @@ impl<MS: MessageStore> TopicRouteInfoManager<MS> {
         });
     }
 
+    pub fn shutdown(&mut self) {
+        warn!("TopicRouteInfoManager shutdown not implemented");
+    }
     async fn update_topic_route_info_from_name_server(&self) {
         let topic_set_for_pop_assignment = self
             .topic_subscribe_info_table