This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch cloud-native
in repository https://gitbox.apache.org/repos/asf/dubbo.git

commit 4cf629d96a520d7afea0ac15256e273ab3ca669a
Author: ken.lj <ken.lj...@gmail.com>
AuthorDate: Tue Aug 27 09:26:55 2019 +0800

    generate urls directly for non-dubbo service instances.
---
 .../org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
 
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
index 5368b56..e728727 100644
--- 
a/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
+++ 
b/dubbo-registry/dubbo-registry-api/src/main/java/org/apache/dubbo/registry/client/ServiceDiscoveryRegistry.java
@@ -76,6 +76,7 @@ import static 
org.apache.dubbo.common.function.ThrowableAction.execute;
 import static org.apache.dubbo.common.utils.CollectionUtils.isEmpty;
 import static org.apache.dubbo.common.utils.CollectionUtils.isEmptyMap;
 import static org.apache.dubbo.common.utils.CollectionUtils.isNotEmpty;
+import static org.apache.dubbo.common.utils.DubboServiceLoader.loadServices;
 import static org.apache.dubbo.common.utils.StringUtils.isBlank;
 import static 
org.apache.dubbo.metadata.WritableMetadataService.DEFAULT_EXTENSION;
 import static 
org.apache.dubbo.registry.client.ServiceDiscoveryFactory.getExtension;
@@ -399,7 +400,7 @@ public class ServiceDiscoveryRegistry extends 
FailbackRegistry {
         if 
(ServiceInstanceMetadataUtils.isDubboServiceInstance(serviceInstances.get(0))) {
             initTemplateURLs(subscribedURL, serviceInstances);
             // Clone the subscribed URLs from the template URLs
-            subscribedURLs = cloneSubscribedURLs(subscribedURL, 
serviceInstances);
+            subscribedURLs = cloneExportedURLs(subscribedURL, 
serviceInstances);
         } else {
             for (ServiceInstance instance : serviceInstances) {
                 URLBuilder builder = new URLBuilder(

Reply via email to