[ISSUE #1576] Delete redundant if statment in select MessageQueue (#1607)

* delete redundant if statment * Correct code style

[ISSUE #1576] Delete redundant if statment in select MessageQueue (#1607)
* delete redundant if statment * Correct code style
30766d22 · SSpirits · GitHub · 3e5008f2 · 30766d22
显示空白变更内容
内联并排

Showing with 2 addition and 4 deletion

client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java ...a/org/apache/rocketmq/client/latency/MQFaultStrategy.java +2 -4

未找到文件。
--- a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
+++ b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
@@ -64,11 +64,9 @@ public class MQFaultStrategy {
                    if (pos < 0)
                        pos = 0;
                    MessageQueue mq = tpInfo.getMessageQueueList().get(pos);
-                    if (latencyFaultTolerance.isAvailable(mq.getBrokerName())) {
-                        if (null == lastBrokerName || mq.getBrokerName().equals(lastBrokerName))
+                    if (latencyFaultTolerance.isAvailable(mq.getBrokerName()))
                        return mq;
                }
-                }

                final String notBestBroker = latencyFaultTolerance.pickOneAtLeast();
                int writeQueueNums = tpInfo.getQueueIdByBroker(notBestBroker);