This is an automated email from the ASF dual-hosted git repository.
lw1243925457 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-shenyu.git
The following commit(s) were added to refs/heads/master by this push:
new 3d13efec0 With nacos, a service can register multiple types of RPC
clients (#3216)
3d13efec0 is described below
commit 3d13efec0643f14c383a330c78f7d13d8accd91c
Author: jerbo99 <[email protected]>
AuthorDate: Wed Apr 13 19:35:06 2022 +0800
With nacos, a service can register multiple types of RPC clients (#3216)
nacos service register is idempotent and a application can have more rpc
type,so the fix is correct.
---
.../shenyu/register/client/nacos/NacosClientRegisterRepository.java | 6 ------
1 file changed, 6 deletions(-)
diff --git
a/shenyu-register-center/shenyu-register-client/shenyu-register-client-nacos/src/main/java/org/apache/shenyu/register/client/nacos/NacosClientRegisterRepository.java
b/shenyu-register-center/shenyu-register-client/shenyu-register-client-nacos/src/main/java/org/apache/shenyu/register/client/nacos/NacosClientRegisterRepository.java
index d735effb5..7fb7c84c7 100644
---
a/shenyu-register-center/shenyu-register-client/shenyu-register-client-nacos/src/main/java/org/apache/shenyu/register/client/nacos/NacosClientRegisterRepository.java
+++
b/shenyu-register-center/shenyu-register-client/shenyu-register-client-nacos/src/main/java/org/apache/shenyu/register/client/nacos/NacosClientRegisterRepository.java
@@ -60,8 +60,6 @@ public class NacosClientRegisterRepository implements
ShenyuClientRegisterReposi
private final ConcurrentLinkedQueue<String> metadataCache = new
ConcurrentLinkedQueue<>();
- private boolean registerService;
-
public NacosClientRegisterRepository() { }
public NacosClientRegisterRepository(final ShenyuRegisterCenterConfig
config) {
@@ -128,10 +126,6 @@ public class NacosClientRegisterRepository implements
ShenyuClientRegisterReposi
final String host,
final int port,
final URIRegisterDTO
registerDTO) {
- if (registerService) {
- return;
- }
- registerService = true;
Instance instance = new Instance();
instance.setEphemeral(true);
instance.setIp(host);