diff --git a/rocketmq-broker/src/broker_runtime.rs b/rocketmq-broker/src/broker_runtime.rs index 6885e1ad..df0da72a 100644 --- a/rocketmq-broker/src/broker_runtime.rs +++ b/rocketmq-broker/src/broker_runtime.rs @@ -1093,11 +1093,13 @@ impl BrokerRuntimeInner { topic_config_wrapper, vec![], oneway, - 10000, - false, - false, - None, - Default::default(), + this.broker_config.register_broker_timeout_mills as u64, + this.broker_config.enable_slave_acting_master, + this.broker_config.compressed_register, + this.broker_config + .enable_slave_acting_master + .then_some(this.broker_config.broker_not_active_timeout_millis), + Default::default(), //optimize this.clone(), ) .await; diff --git a/rocketmq-common/src/common/broker/broker_config.rs b/rocketmq-common/src/common/broker/broker_config.rs index 059d8671..108e780a 100644 --- a/rocketmq-common/src/common/broker/broker_config.rs +++ b/rocketmq-common/src/common/broker/broker_config.rs @@ -197,6 +197,8 @@ pub struct BrokerConfig { pub revive_scan_time: u64, pub enable_skip_long_awaiting_ack: bool, pub skip_when_ck_re_put_reach_max_times: bool, + pub compressed_register: bool, + pub broker_not_active_timeout_millis: i64, } impl Default for BrokerConfig { @@ -299,6 +301,8 @@ impl Default for BrokerConfig { revive_scan_time: 10_000, enable_skip_long_awaiting_ack: false, skip_when_ck_re_put_reach_max_times: false, + compressed_register: false, + broker_not_active_timeout_millis: 10_000, } } }