Repository: incubator-rocketmq Updated Branches: refs/heads/develop 3fe7535bc -> 15af63e23
[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/15af63e2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/15af63e2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/15af63e2 Branch: refs/heads/develop Commit: 15af63e23b8649537cce56a831c7f965451ce399 Parents: 3fe7535 Author: yukon <yu...@apache.org> Authored: Fri Mar 24 11:05:19 2017 +0800 Committer: yukon <yu...@apache.org> Committed: Fri Mar 24 11:05:19 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/15af63e2/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 ebcfb62..7b14860 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();
