mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
[ISSUE #6077] fix issues that messageStore could be null
This commit is contained in:
@@ -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();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user