You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by al...@apache.org on 2021/09/27 11:01:03 UTC
[dubbo] branch master updated: MultipleRegistry remove duplicate
URL (#8899)
This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/master by this push:
new 4af5925 MultipleRegistry remove duplicate URL (#8899)
4af5925 is described below
commit 4af59252c1dfb4027b45322c7094e9247e3c835e
Author: Wang Chengming <63...@qq.com>
AuthorDate: Mon Sep 27 19:00:20 2021 +0800
MultipleRegistry remove duplicate URL (#8899)
---
.../java/org/apache/dubbo/registry/multiple/MultipleRegistry.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/dubbo-registry/dubbo-registry-multiple/src/main/java/org/apache/dubbo/registry/multiple/MultipleRegistry.java b/dubbo-registry/dubbo-registry-multiple/src/main/java/org/apache/dubbo/registry/multiple/MultipleRegistry.java
index 8ae4488..fecd0db 100644
--- a/dubbo-registry/dubbo-registry-multiple/src/main/java/org/apache/dubbo/registry/multiple/MultipleRegistry.java
+++ b/dubbo-registry/dubbo-registry-multiple/src/main/java/org/apache/dubbo/registry/multiple/MultipleRegistry.java
@@ -35,6 +35,7 @@ import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
+import java.util.stream.Collectors;
import static org.apache.dubbo.common.constants.RegistryConstants.EMPTY_PROTOCOL;
@@ -205,14 +206,14 @@ public class MultipleRegistry extends AbstractRegistry {
@Override
public List<URL> lookup(URL url) {
- List<URL> urls = new ArrayList<URL>();
+ List<URL> urls = new ArrayList<>();
for (Registry registry : referenceRegistries.values()) {
List<URL> tmpUrls = registry.lookup(url);
if (!CollectionUtils.isEmpty(tmpUrls)) {
urls.addAll(tmpUrls);
}
}
- return urls;
+ return urls.stream().distinct().collect(Collectors.toList());
}
protected void init() {