From cc4c19642cf03f3c41debd241c5f5c75274ef1af Mon Sep 17 00:00:00 2001 From: RongtongJin Date: Thu, 14 Jul 2022 11:56:15 +0800 Subject: [PATCH] Change the loading order of HAService --- .../apache/rocketmq/store/DefaultMessageStore.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 0c88f3b6a2a..1b15dc0e243 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -189,13 +189,14 @@ public DefaultMessageStore(final MessageStoreConfig messageStoreConfig, final Br this.correctLogicOffsetService = new CorrectLogicOffsetService(); this.storeStatsService = new StoreStatsService(getBrokerIdentity()); this.indexService = new IndexService(this); + if (!messageStoreConfig.isEnableDLegerCommitLog() && !this.messageStoreConfig.isDuplicationEnable()) { - this.haService = ServiceProvider.loadClass(ServiceProvider.HA_SERVICE_ID, HAService.class); - if (null == this.haService) { - if (brokerConfig.isEnableControllerMode()) { - this.haService = new AutoSwitchHAService(); - LOGGER.warn("Load AutoSwitch HA Service: {}", AutoSwitchHAService.class.getSimpleName()); - } else { + if (brokerConfig.isEnableControllerMode()) { + this.haService = new AutoSwitchHAService(); + LOGGER.warn("Load AutoSwitch HA Service: {}", AutoSwitchHAService.class.getSimpleName()); + } else { + this.haService = ServiceProvider.loadClass(ServiceProvider.HA_SERVICE_ID, HAService.class); + if (null == this.haService) { this.haService = new DefaultHAService(); LOGGER.warn("Load default HA Service: {}", DefaultHAService.class.getSimpleName()); }