提交 12b6b9e6 编写于 作者: Y yukon

[ROCKETMQ-32] Reuse local variable brokerAddrs, thanks @naughtybear, closes...

[ROCKETMQ-32] Reuse local variable brokerAddrs, thanks @naughtybear, closes apache/incubator-rocketmq#8
上级 dbdb0720
...@@ -610,7 +610,7 @@ public class RouteInfoManager { ...@@ -610,7 +610,7 @@ public class RouteInfoManager {
while (it.hasNext()) { while (it.hasNext()) {
BrokerData bd = brokerAddrTable.get(it.next()); BrokerData bd = brokerAddrTable.get(it.next());
HashMap<Long, String> brokerAddrs = bd.getBrokerAddrs(); HashMap<Long, String> brokerAddrs = bd.getBrokerAddrs();
if (bd.getBrokerAddrs() != null && !bd.getBrokerAddrs().isEmpty()) { if (brokerAddrs != null && !brokerAddrs.isEmpty()) {
Iterator<Long> it2 = brokerAddrs.keySet().iterator(); Iterator<Long> it2 = brokerAddrs.keySet().iterator();
topicList.setBrokerAddr(brokerAddrs.get(it2.next())); topicList.setBrokerAddr(brokerAddrs.get(it2.next()));
break; break;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册