[ISSUE #2279]🚀BrokerFastFailure and BrokerPreOnlineService add start …

…method
mxsm · Jan 16, 2025 · fa6f6a0 · fa6f6a0
1 parent 1c3b29c
commit fa6f6a0
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/rocketmq-broker/src/broker/broker_pre_online_service.rs b/rocketmq-broker/src/broker/broker_pre_online_service.rs
@@ -19,6 +19,11 @@ use tracing::warn;
 pub struct BrokerPreOnlineService;
 
 impl BrokerPreOnlineService {
+
+    pub fn start(&mut self) {
+        warn!("BrokerPreOnlineService started not implemented");
+    }
+
     pub fn shutdown(&mut self) {
         warn!("BrokerPreOnlineService shutdown not implemented");
     }

diff --git a/rocketmq-broker/src/latency/broker_fast_failure.rs b/rocketmq-broker/src/latency/broker_fast_failure.rs
@@ -19,6 +19,11 @@ use tracing::warn;
 pub struct BrokerFastFailure;
 
 impl BrokerFastFailure {
+
+    pub fn start(&mut self) {
+        warn!("BrokerFastFailure started not implemented");
+    }
+
     pub fn shutdown(&mut self) {
         warn!("BrokerFastFailure shutdown not implemented");
     }