diff --git a/rocketmq-broker/src/broker/broker_pre_online_service.rs b/rocketmq-broker/src/broker/broker_pre_online_service.rs index 3fddd892..2137a988 100644 --- a/rocketmq-broker/src/broker/broker_pre_online_service.rs +++ b/rocketmq-broker/src/broker/broker_pre_online_service.rs @@ -19,11 +19,10 @@ 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 index a5b36fd0..8aac6b29 100644 --- a/rocketmq-broker/src/latency/broker_fast_failure.rs +++ b/rocketmq-broker/src/latency/broker_fast_failure.rs @@ -19,7 +19,6 @@ use tracing::warn; pub struct BrokerFastFailure; impl BrokerFastFailure { - pub fn start(&mut self) { warn!("BrokerFastFailure started not implemented"); }