use the correct spi ZookeeperTransporter when initialize the default …

…ConfigCenter's zkClient(#4511)
apache · Jul 9, 2019 · b52730f · b52730f
1 parent 519df67
commit b52730f
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/...onfig/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java b/...onfig/dubbo-config-api/src/main/java/org/apache/dubbo/config/AbstractInterfaceConfig.java
@@ -619,6 +619,7 @@ private void useRegistryForConfigIfNecessary() {
             Environment.getInstance().getDynamicConfiguration().orElseGet(() -> {
                 ConfigManager configManager = ConfigManager.getInstance();
                 ConfigCenterConfig cc = configManager.getConfigCenter().orElse(new ConfigCenterConfig());
+                cc.setClient(rc.getClient());
                 cc.setProtocol(rc.getProtocol());
                 cc.setAddress(rc.getAddress());
                 cc.setHighestPriority(false);

diff --git a/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ConfigCenterConfig.java b/dubbo-config/dubbo-config-api/src/main/java/org/apache/dubbo/config/ConfigCenterConfig.java
@@ -86,6 +86,11 @@ public class ConfigCenterConfig extends AbstractConfig {
      */
     private Map<String, String> parameters;
 
+    /*
+     *     as same as org.apache.dubbo.config.RegistryConfig.client
+      */
+    private String client;
+
     public ConfigCenterConfig() {
     }
 
@@ -228,6 +233,14 @@ public void setParameters(Map<String, String> parameters) {
         this.parameters = parameters;
     }
 
+    public String getClient() {
+        return client;
+    }
+
+    public void setClient(String client) {
+        this.client = client;
+    }
+
     @Override
     @Parameter(excluded = true)
     public boolean isValid() {