Repository: incubator-rocketmq Updated Branches: refs/heads/master dbdb07209 -> 12b6b9e64
[ROCKETMQ-32] Reuse local variable brokerAddrs, thanks @naughtybear, closes apache/incubator-rocketmq#8 Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/12b6b9e6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/12b6b9e6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/12b6b9e6 Branch: refs/heads/master Commit: 12b6b9e64470e61591d2ec0dbdc49a74a056224c Parents: dbdb072 Author: yukon <[email protected]> Authored: Mon Jan 16 16:53:30 2017 +0800 Committer: yukon <[email protected]> Committed: Mon Jan 16 16:53:30 2017 +0800 ---------------------------------------------------------------------- .../org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/12b6b9e6/namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java ---------------------------------------------------------------------- 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 69b64ca..16b7847 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<Long, String> brokerAddrs = bd.getBrokerAddrs(); - if (bd.getBrokerAddrs() != null && !bd.getBrokerAddrs().isEmpty()) { + if (brokerAddrs != null && !brokerAddrs.isEmpty()) { Iterator<Long> it2 = brokerAddrs.keySet().iterator(); topicList.setBrokerAddr(brokerAddrs.get(it2.next())); break;
