From eb1af6113855ea764e512f629a3642b61c782d5d Mon Sep 17 00:00:00 2001
From: zyn <429276924@qq.com>
Date: Thu, 10 Jan 2019 13:38:45 +0800
Subject: [PATCH] sendLatencyFaultEnable logical optimization

---
 .../org/apache/rocketmq/client/latency/MQFaultStrategy.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
index 7854fcb7d10..e1e4c2587e7 100644
--- a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
+++ b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
@@ -65,8 +65,7 @@ public MessageQueue selectOneMessageQueue(final TopicPublishInfo tpInfo, final S
                         pos = 0;
                     MessageQueue mq = tpInfo.getMessageQueueList().get(pos);
                     if (latencyFaultTolerance.isAvailable(mq.getBrokerName())) {
-                        if (null == lastBrokerName || mq.getBrokerName().equals(lastBrokerName))
-                            return mq;
+                        return mq;
                     }
                 }