optimize the broker electing switch's branch.

apache · Mar 16, 2023 · 77893ef · 77893ef
1 parent ec7acfb
commit 77893ef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java b/broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
@@ -1185,8 +1185,8 @@ public Pair<ElectMasterResponseHeader, Set<Long>> brokerElect(String controllerA
                 throw new MQBrokerException(response.getCode(), "Controller leader was changed");
             }
             case CONTROLLER_BROKER_NEED_TO_BE_REGISTERED:
-                throw new MQBrokerException(response.getCode(), response.getRemark());
             case CONTROLLER_ELECT_MASTER_FAILED:
+                throw new MQBrokerException(response.getCode(), response.getRemark());
             case CONTROLLER_MASTER_STILL_EXIST:
             case SUCCESS:
                 final ElectMasterResponseHeader responseHeader = (ElectMasterResponseHeader) response.decodeCommandCustomHeader(ElectMasterResponseHeader.class);