diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index a96aa04054..15cf66f7a5 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -770,10 +770,9 @@ public class BrokerController { } if (messageStore != null) { registerMessageStoreHook(); + result = result && this.messageStore.load(); } - result = result && this.messageStore.load(); - if (messageStoreConfig.isTimerWheelEnable()) { result = result && this.timerMessageStore.load(); }