You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2017/01/16 08:53:45 UTC
incubator-rocketmq git commit: [ROCKETMQ-32] Reuse local variable
brokerAddrs, thanks @naughtybear, closes apache/incubator-rocketmq#8
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 <yu...@apache.org>
Authored: Mon Jan 16 16:53:30 2017 +0800
Committer: yukon <yu...@apache.org>
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;