fizzgate/fizz-gateway-node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adjust id visibility of FizzServiceRegistration.java

Browse Source
This commit is contained in:
hongqiaowei
2021-12-24 18:26:10 +08:00
parent ac8f923f88
commit 31d58fadd5
3 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fizz-core/src/main/java/we/service_registry/FizzServiceRegistration.java
View File

@@ -32,7 +32,7 @@ public abstract class FizzServiceRegistration {
protected static final Logger log = LoggerFactory.getLogger(FizzServiceRegistration.class); protected static final Logger log = LoggerFactory.getLogger(FizzServiceRegistration.class);
protected String id; private String id;
private Registration registration; private Registration registration;
@@ -44,6 +44,10 @@ public abstract class FizzServiceRegistration {
this.serviceRegistry = serviceRegistry; this.serviceRegistry = serviceRegistry;
} }
public String getId() {
return id;
}
public void register() { public void register() {
serviceRegistry.register(registration); serviceRegistry.register(registration);
} }

2
fizz-core/src/main/java/we/service_registry/eureka/FizzEurekaServiceRegistration.java
View File

@@ -148,7 +148,7 @@ public class FizzEurekaServiceRegistration extends FizzServiceRegistration {
public InstanceInfo getInstanceInfo(String service) { public InstanceInfo getInstanceInfo(String service) {
List<InstanceInfo> insts = client.getInstancesByVipAddress(service, false); List<InstanceInfo> insts = client.getInstancesByVipAddress(service, false);
if (CollectionUtils.isEmpty(insts)) { if (CollectionUtils.isEmpty(insts)) {
throw Utils.runtimeExceptionWithoutStack(id + " eureka no " + service); throw Utils.runtimeExceptionWithoutStack(getId() + " eureka no " + service);
} }
Applications apps = client.getApplications(); Applications apps = client.getApplications();
int index = (int) (apps.getNextIndex(service.toUpperCase(), false).incrementAndGet() % insts.size()); int index = (int) (apps.getNextIndex(service.toUpperCase(), false).incrementAndGet() % insts.size());

4
fizz-core/src/main/java/we/service_registry/nacos/FizzNacosServiceRegistration.java
View File

@@ -82,7 +82,7 @@ public class FizzNacosServiceRegistration extends FizzServiceRegistration {
return RegistryCenter.Status.DOWN; return RegistryCenter.Status.DOWN;
} else { } else {
log.warn("{} status is {}", id, status); log.warn("{} status is {}", getId(), status);
return RegistryCenter.Status.UNKNOWN; return RegistryCenter.Status.UNKNOWN;
} }
} }
@@ -119,7 +119,7 @@ public class FizzNacosServiceRegistration extends FizzServiceRegistration {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
if (instance == null) { if (instance == null) {
throw Utils.runtimeExceptionWithoutStack(id + " nacos no " + service); throw Utils.runtimeExceptionWithoutStack(getId() + " nacos no " + service);
} }
return instance; return instance;
} }