Repository: incubator-rocketmq Updated Branches: refs/heads/master 4df3155ba -> fa85abcdf
[ROCKETMQ-153][HOTFIX] Fetch name server address dynamically. Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/fa85abcd Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/fa85abcd Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/fa85abcd Branch: refs/heads/master Commit: fa85abcdf6ee46e56403ddf86828a38683103fd0 Parents: 4df3155 Author: yukon <yu...@apache.org> Authored: Fri Mar 24 11:05:19 2017 +0800 Committer: yukon <yu...@apache.org> Committed: Fri Mar 24 11:07:01 2017 +0800 ---------------------------------------------------------------------- .../org/apache/rocketmq/client/impl/factory/MQClientInstance.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/fa85abcd/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java ---------------------------------------------------------------------- diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java index 1343e76..b0c3b04 100644 --- a/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java +++ b/client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java @@ -223,7 +223,7 @@ public class MQClientInstance { this.serviceState = ServiceState.START_FAILED; // If not specified,looking address from name server if (null == this.clientConfig.getNamesrvAddr()) { - this.clientConfig.setNamesrvAddr(this.mQClientAPIImpl.fetchNameServerAddr()); + this.mQClientAPIImpl.fetchNameServerAddr(); } // Start request-response channel this.mQClientAPIImpl.start();
