This is an automated email from the ASF dual-hosted git repository.
yunlong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new cf0ec09c67 Fix the issue of multiple selectors connecting to different
registry centers. (#6218)
cf0ec09c67 is described below
commit cf0ec09c672a5350b87075873d66f8656a8e2726
Author: yunlongn <[email protected]>
AuthorDate: Mon Nov 3 10:42:15 2025 +0800
Fix the issue of multiple selectors connecting to different registry
centers. (#6218)
Co-authored-by: moremind <[email protected]>
---
.../registry/apollo/ApolloInstanceRegisterRepository.java | 2 +-
.../registry/consul/ConsulInstanceRegisterRepository.java | 2 +-
.../registry/etcd/EtcdInstanceRegisterRepository.java | 2 +-
.../registry/eureka/EurekaInstanceRegisterRepository.java | 2 +-
.../kubernetes/KubernetesInstanceRegisterRepository.java | 2 +-
.../registry/nacos/NacosInstanceRegisterRepository.java | 2 +-
.../registry/polaris/PolarisInstanceRegisterRepository.java | 13 ++++++-------
.../zookeeper/ZookeeperInstanceRegisterRepository.java | 2 +-
8 files changed, 13 insertions(+), 14 deletions(-)
diff --git
a/shenyu-registry/shenyu-registry-apollo/src/main/java/org/apache/shenyu/registry/apollo/ApolloInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-apollo/src/main/java/org/apache/shenyu/registry/apollo/ApolloInstanceRegisterRepository.java
index eac14b52e2..6c5440a130 100644
---
a/shenyu-registry/shenyu-registry-apollo/src/main/java/org/apache/shenyu/registry/apollo/ApolloInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-apollo/src/main/java/org/apache/shenyu/registry/apollo/ApolloInstanceRegisterRepository.java
@@ -45,7 +45,7 @@ import java.util.stream.Collectors;
/**
* The type apollo instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class ApolloInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final String APOLLO_CLUSTER = "apollo.cluster";
diff --git
a/shenyu-registry/shenyu-registry-consul/src/main/java/org/apache/shenyu/registry/consul/ConsulInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-consul/src/main/java/org/apache/shenyu/registry/consul/ConsulInstanceRegisterRepository.java
index 259c33eede..b8f56fc231 100644
---
a/shenyu-registry/shenyu-registry-consul/src/main/java/org/apache/shenyu/registry/consul/ConsulInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-consul/src/main/java/org/apache/shenyu/registry/consul/ConsulInstanceRegisterRepository.java
@@ -57,7 +57,7 @@ import java.util.stream.Collectors;
/**
* The type Consul instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class ConsulInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(ConsulInstanceRegisterRepository.class);
diff --git
a/shenyu-registry/shenyu-registry-etcd/src/main/java/org/apache/shenyu/registry/etcd/EtcdInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-etcd/src/main/java/org/apache/shenyu/registry/etcd/EtcdInstanceRegisterRepository.java
index 4181bee856..111a6528f6 100644
---
a/shenyu-registry/shenyu-registry-etcd/src/main/java/org/apache/shenyu/registry/etcd/EtcdInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-etcd/src/main/java/org/apache/shenyu/registry/etcd/EtcdInstanceRegisterRepository.java
@@ -50,7 +50,7 @@ import static java.nio.charset.StandardCharsets.UTF_8;
/**
* The type Etcd instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class EtcdInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(EtcdInstanceRegisterRepository.class);
diff --git
a/shenyu-registry/shenyu-registry-eureka/src/main/java/org/apache/shenyu/registry/eureka/EurekaInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-eureka/src/main/java/org/apache/shenyu/registry/eureka/EurekaInstanceRegisterRepository.java
index 857f3c5a2c..334e7a49bb 100644
---
a/shenyu-registry/shenyu-registry-eureka/src/main/java/org/apache/shenyu/registry/eureka/EurekaInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-eureka/src/main/java/org/apache/shenyu/registry/eureka/EurekaInstanceRegisterRepository.java
@@ -60,7 +60,7 @@ import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
-@Join
+@Join(isSingleton = false)
public class EurekaInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(EurekaInstanceRegisterRepository.class);
diff --git
a/shenyu-registry/shenyu-registry-kubernetes/src/main/java/org/apache/shenyu/registry/kubernetes/KubernetesInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-kubernetes/src/main/java/org/apache/shenyu/registry/kubernetes/KubernetesInstanceRegisterRepository.java
index 25e4f487e6..6a44d91261 100644
---
a/shenyu-registry/shenyu-registry-kubernetes/src/main/java/org/apache/shenyu/registry/kubernetes/KubernetesInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-kubernetes/src/main/java/org/apache/shenyu/registry/kubernetes/KubernetesInstanceRegisterRepository.java
@@ -31,7 +31,7 @@ import java.util.stream.Collectors;
/**
* The type kubernetes instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class KubernetesInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private KubernetesClient kubernetesClient;
diff --git
a/shenyu-registry/shenyu-registry-nacos/src/main/java/org/apache/shenyu/registry/nacos/NacosInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-nacos/src/main/java/org/apache/shenyu/registry/nacos/NacosInstanceRegisterRepository.java
index 1044a06a9d..d643dc3da3 100644
---
a/shenyu-registry/shenyu-registry-nacos/src/main/java/org/apache/shenyu/registry/nacos/NacosInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-nacos/src/main/java/org/apache/shenyu/registry/nacos/NacosInstanceRegisterRepository.java
@@ -54,7 +54,7 @@ import java.util.stream.Collectors;
/**
* The type Nacos instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class NacosInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(NacosInstanceRegisterRepository.class);
diff --git
a/shenyu-registry/shenyu-registry-polaris/src/main/java/org/apache/shenyu/registry/polaris/PolarisInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-polaris/src/main/java/org/apache/shenyu/registry/polaris/PolarisInstanceRegisterRepository.java
index ba73795ff7..59214d8992 100644
---
a/shenyu-registry/shenyu-registry-polaris/src/main/java/org/apache/shenyu/registry/polaris/PolarisInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-polaris/src/main/java/org/apache/shenyu/registry/polaris/PolarisInstanceRegisterRepository.java
@@ -28,11 +28,6 @@ import com.tencent.polaris.api.rpc.InstancesResponse;
import com.tencent.polaris.client.api.SDKContext;
import com.tencent.polaris.factory.ConfigAPIFactory;
import com.tencent.polaris.factory.api.DiscoveryAPIFactory;
-
-import java.net.URI;
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.List;
import org.apache.shenyu.common.constant.Constants;
import org.apache.shenyu.common.constant.PolarisPathConstants;
import org.apache.shenyu.common.exception.ShenyuException;
@@ -40,14 +35,18 @@ import
org.apache.shenyu.registry.api.ShenyuInstanceRegisterRepository;
import org.apache.shenyu.registry.api.config.RegisterConfig;
import org.apache.shenyu.registry.api.entity.InstanceEntity;
import org.apache.shenyu.spi.Join;
-
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.net.URI;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
/**
* The type polaris instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class PolarisInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(PolarisInstanceRegisterRepository.class);
diff --git
a/shenyu-registry/shenyu-registry-zookeeper/src/main/java/org/apache/shenyu/registry/zookeeper/ZookeeperInstanceRegisterRepository.java
b/shenyu-registry/shenyu-registry-zookeeper/src/main/java/org/apache/shenyu/registry/zookeeper/ZookeeperInstanceRegisterRepository.java
index f211283996..d639871c3f 100644
---
a/shenyu-registry/shenyu-registry-zookeeper/src/main/java/org/apache/shenyu/registry/zookeeper/ZookeeperInstanceRegisterRepository.java
+++
b/shenyu-registry/shenyu-registry-zookeeper/src/main/java/org/apache/shenyu/registry/zookeeper/ZookeeperInstanceRegisterRepository.java
@@ -53,7 +53,7 @@ import java.util.stream.Collectors;
/**
* The type Zookeeper instance register repository.
*/
-@Join
+@Join(isSingleton = false)
public class ZookeeperInstanceRegisterRepository implements
ShenyuInstanceRegisterRepository {
private static final Logger LOGGER =
LoggerFactory.getLogger(ZookeeperInstanceRegisterRepository.class);
