study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

fix bug for ansServer id

Browse Source
This commit is contained in:
得少 2019-01-10 11:44:49 +08:00
parent e163500980
commit b16ef5efea
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-alicloud-ans/src/main/java/org/springframework/cloud/alicloud/ans/migrate/ServerListInvocationHandler.java
View File

@ -88,17 +88,17 @@ class ServerListInvocationHandler implements MethodInterceptor {
ansServerList.forEach(ansServer -> { ansServerList.forEach(ansServer -> {
if (server.getHostPort() if (server.getHostPort()
.equals(ansServer.getHealthService().toInetAddr())) { .equals(ansServer.getHealthService().toInetAddr())) {
// fix bug: mast be set the zone, update server list,will filter
// by: ZoneAffinityPredicate // by: ZoneAffinityPredicate
ansServer.setZone(server.getZone());
ansServer.setSchemea(server.getScheme());
ansServer.setId(server.getId());
ansServer.setReadyToServe(true);
serverIterator.remove(); serverIterator.remove();
log.info("Source Server is remove " + server.getHostPort() log.info("Source Server is remove " + server.getHostPort()
+ ", and from ANS Server is override：" + ", and from ANS Server is override："
+ ansServer.toString()); + ansServer.toString());
} }
// fix bug: mast be set the zone, update server list,will filter
ansServer.setZone(server.getZone());
ansServer.setSchemea(server.getScheme());
ansServer.setId(ansServer.getHealthService().toInetAddr());
ansServer.setReadyToServe(true);
}); });
} }