You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by vi...@apache.org on 2019/09/24 09:27:39 UTC
[dubbo] branch 2.7.4-release updated: Apollo config center
optimization,
use 'dubbo.properties' as default namespace for properties. (#5105)
This is an automated email from the ASF dual-hosted git repository.
victory pushed a commit to branch 2.7.4-release
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/2.7.4-release by this push:
new 13ddecb Apollo config center optimization, use 'dubbo.properties' as default namespace for properties. (#5105)
13ddecb is described below
commit 13ddecba0e4d7546591b9d93479dc7e58895d2ac
Author: ken.lj <ke...@gmail.com>
AuthorDate: Tue Sep 24 17:27:24 2019 +0800
Apollo config center optimization, use 'dubbo.properties' as default namespace for properties. (#5105)
---
.../support/apollo/ApolloDynamicConfiguration.java | 19 ++++++++-----------
1 file changed, 8 insertions(+), 11 deletions(-)
diff --git a/dubbo-configcenter/dubbo-configcenter-apollo/src/main/java/org/apache/dubbo/configcenter/support/apollo/ApolloDynamicConfiguration.java b/dubbo-configcenter/dubbo-configcenter-apollo/src/main/java/org/apache/dubbo/configcenter/support/apollo/ApolloDynamicConfiguration.java
index bcc9a38..c668746 100644
--- a/dubbo-configcenter/dubbo-configcenter-apollo/src/main/java/org/apache/dubbo/configcenter/support/apollo/ApolloDynamicConfiguration.java
+++ b/dubbo-configcenter/dubbo-configcenter-apollo/src/main/java/org/apache/dubbo/configcenter/support/apollo/ApolloDynamicConfiguration.java
@@ -48,6 +48,7 @@ import static org.apache.dubbo.common.constants.CommonConstants.CHECK_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.CLUSTER_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.COMMA_SPLIT_PATTERN;
import static org.apache.dubbo.common.constants.CommonConstants.CONFIG_NAMESPACE_KEY;
+import static org.apache.dubbo.common.constants.CommonConstants.GROUP_KEY;
/**
* Apollo implementation, https://github.com/ctripcorp/apollo
@@ -81,8 +82,11 @@ public class ApolloDynamicConfiguration implements DynamicConfiguration {
System.setProperty(APOLLO_CLUSTER_KEY, configCluster);
}
- dubboConfig = ConfigService.getConfig(url.getParameter(CONFIG_NAMESPACE_KEY, DEFAULT_GROUP));
- dubboConfigFile = ConfigService.getConfigFile(url.getParameter(CONFIG_NAMESPACE_KEY, DEFAULT_GROUP), ConfigFileFormat.Properties);
+ String namespace = url.getParameter(CONFIG_NAMESPACE_KEY, DEFAULT_GROUP);
+ String apolloNamespace = StringUtils.isEmpty(namespace) ? url.getParameter(GROUP_KEY, DEFAULT_GROUP) : namespace;
+ dubboConfig = ConfigService.getConfig(apolloNamespace);
+ dubboConfigFile = ConfigService.getConfigFile(apolloNamespace, ConfigFileFormat.Properties);
+
// Decide to fail or to continue when failed to connect to remote server.
boolean check = url.getParameter(CHECK_KEY, true);
if (dubboConfig.getSourceType() != ConfigSourceType.REMOTE) {
@@ -148,16 +152,9 @@ public class ApolloDynamicConfiguration implements DynamicConfiguration {
@Override
public String getProperties(String key, String group, long timeout) throws IllegalStateException {
- if (StringUtils.isEmpty(group)) {
- return dubboConfigFile.getContent();
- }
- if (group.equals(url.getParameter(APPLICATION_KEY))) {
- return ConfigService.getConfigFile(APOLLO_APPLICATION_KEY, ConfigFileFormat.Properties).getContent();
- }
-
- ConfigFile configFile = ConfigService.getConfigFile(group, ConfigFileFormat.Properties);
+ ConfigFile configFile = ConfigService.getConfigFile(key, ConfigFileFormat.Properties);
if (configFile == null) {
- throw new IllegalStateException("There is no namespace named " + group + " in Apollo.");
+ throw new IllegalStateException("There is no namespace named " + key + " in Apollo.");
}
return configFile.getContent();
}