[ISSUE #3381] Fix bug of when role change but not register again (#3442)

apache · Nov 3, 2021 · 2385f04 · 2385f04
1 parent 1657475
commit 2385f04
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -1182,7 +1182,7 @@ public void changeToSlave(int brokerId) {
         handleSlaveSynchronize(BrokerRole.SLAVE);
 
         try {
-            this.registerBrokerAll(true, true, brokerConfig.isForceRegister());
+            this.registerBrokerAll(true, true, true);
         } catch (Throwable ignored) {
 
         }
@@ -1219,7 +1219,7 @@ public void changeToMaster(BrokerRole role) {
         messageStoreConfig.setBrokerRole(role);
 
         try {
-            this.registerBrokerAll(true, true, brokerConfig.isForceRegister());
+            this.registerBrokerAll(true, true, true);
         } catch (Throwable ignored) {
 
         }