You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by mi...@apache.org on 2018/11/22 09:26:16 UTC
[incubator-dubbo-ops] branch metadata updated: fix root path
This is an automated email from the ASF dual-hosted git repository.
min pushed a commit to branch metadata
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo-ops.git
The following commit(s) were added to refs/heads/metadata by this push:
new ef643c1 fix root path
ef643c1 is described below
commit ef643c1e73965570ef1ee73610a22931ebcabb37
Author: nzomkxia <z8...@gmail.com>
AuthorDate: Thu Nov 22 17:26:21 2018 +0800
fix root path
---
.../dubbo/admin/data/metadata/impl/ZookeeperMetaDataCollector.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/dubbo-admin-backend/src/main/java/org/apache/dubbo/admin/data/metadata/impl/ZookeeperMetaDataCollector.java b/dubbo-admin-backend/src/main/java/org/apache/dubbo/admin/data/metadata/impl/ZookeeperMetaDataCollector.java
index 2e65aff..da980c7 100644
--- a/dubbo-admin-backend/src/main/java/org/apache/dubbo/admin/data/metadata/impl/ZookeeperMetaDataCollector.java
+++ b/dubbo-admin-backend/src/main/java/org/apache/dubbo/admin/data/metadata/impl/ZookeeperMetaDataCollector.java
@@ -31,8 +31,12 @@ public class ZookeeperMetaDataCollector implements MetaDataCollector {
@Override
public void init() {
+ String group = url.getParameter(Constants.GROUP_KEY, DEFAULT_ROOT);
+ if (!group.startsWith(Constants.PATH_SEPARATOR)) {
+ group = Constants.PATH_SEPARATOR + group;
+ }
+ root = group;
client = CuratorFrameworkFactory.newClient(url.getAddress(), new ExponentialBackoffRetry(1000, 3));
- root = url.getParameter(Constants.GROUP_KEY) == null ? DEFAULT_ROOT : url.getParameter(Constants.GROUP_KEY);
client.start();
}