From 12b6b9e64470e61591d2ec0dbdc49a74a056224c Mon Sep 17 00:00:00 2001 From: yukon Date: Mon, 16 Jan 2017 16:53:30 +0800 Subject: [PATCH] [ROCKETMQ-32] Reuse local variable brokerAddrs, thanks @naughtybear, closes apache/incubator-rocketmq#8 --- .../org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java index 69b64ca7..16b7847a 100644 --- a/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java +++ b/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java @@ -610,7 +610,7 @@ public class RouteInfoManager { while (it.hasNext()) { BrokerData bd = brokerAddrTable.get(it.next()); HashMap brokerAddrs = bd.getBrokerAddrs(); - if (bd.getBrokerAddrs() != null && !bd.getBrokerAddrs().isEmpty()) { + if (brokerAddrs != null && !brokerAddrs.isEmpty()) { Iterator it2 = brokerAddrs.keySet().iterator(); topicList.setBrokerAddr(brokerAddrs.get(it2.next())); break; -- GitLab