[ISSUE #2281]🚀BrokerStatsManager and ColdDataCgCtrService add start m…

…ethod
mxsm · Jan 16, 2025 · ddeb110 · ddeb110
1 parent a3e692a
commit ddeb110
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/rocketmq-broker/src/coldctr/cold_data_pull_request_hold_service.rs b/rocketmq-broker/src/coldctr/cold_data_pull_request_hold_service.rs
@@ -21,6 +21,9 @@ pub const NO_SUSPEND_KEY: &str = "_noSuspend_";
 pub struct ColdDataPullRequestHoldService {}
 
 impl ColdDataPullRequestHoldService {
+    pub fn start(&mut self) {
+        warn!("ColdDataPullRequestHoldService started not implemented");
+    }
     pub fn shutdown(&mut self) {
         warn!("ColdDataPullRequestHoldService shutdown not implemented");
     }

diff --git a/rocketmq-broker/src/processor/notification_processor.rs b/rocketmq-broker/src/processor/notification_processor.rs
@@ -22,6 +22,10 @@ use tracing::warn;
 pub struct NotificationProcessor {}
 
 impl NotificationProcessor {
+    pub fn start(&mut self) {
+        warn!("NotificationProcessor started unimplemented, need to implement it");
+    }
+
     fn process_request(
         &self,
         _ctx: ConnectionHandlerContext,