This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/dubbo-admin.git
The following commit(s) were added to refs/heads/develop by this push:
new 77683ba7 fix:Fix init of `ServiceMapping` when metadata center uses
nacos. (#1148)
77683ba7 is described below
commit 77683ba76fb5573b30be0a6e61d809951da7e815
Author: wuwen <[email protected]>
AuthorDate: Fri Aug 25 13:53:12 2023 +0800
fix:Fix init of `ServiceMapping` when metadata center uses nacos. (#1148)
---
.../src/main/java/org/apache/dubbo/admin/config/ConfigCenter.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/config/ConfigCenter.java
b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/config/ConfigCenter.java
index 6a178d61..f27d3af5 100644
---
a/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/config/ConfigCenter.java
+++
b/dubbo-admin-server/src/main/java/org/apache/dubbo/admin/config/ConfigCenter.java
@@ -22,6 +22,7 @@ import org.apache.dubbo.admin.common.util.Constants;
import org.apache.dubbo.admin.registry.config.GovernanceConfiguration;
import org.apache.dubbo.admin.registry.mapping.AdminMappingListener;
import org.apache.dubbo.admin.registry.mapping.ServiceMapping;
+import org.apache.dubbo.admin.registry.mapping.impl.NacosServiceMapping;
import org.apache.dubbo.admin.registry.mapping.impl.NoOpServiceMapping;
import org.apache.dubbo.admin.registry.metadata.MetaDataCollector;
import org.apache.dubbo.admin.service.impl.InstanceRegistryCache;
@@ -203,7 +204,11 @@ public class ConfigCenter {
MappingListener mappingListener = new
AdminMappingListener(serviceDiscovery, instanceRegistryCache);
serviceMapping =
ExtensionLoader.getExtensionLoader(ServiceMapping.class).getExtension(metadataUrl.getProtocol());
serviceMapping.addMappingListener(mappingListener);
- serviceMapping.init(metadataUrl);
+ if (serviceMapping instanceof NacosServiceMapping) {
+ serviceMapping.init(registryUrl);
+ } else {
+ serviceMapping.init(metadataUrl);
+ }
return serviceMapping;
}