SpringCloud/spring-cloud-kubernetes
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes #731

Browse Source
This commit is contained in:
Ryan Baxter
2021-02-10 13:45:40 -05:00
parent c52a3c4561
commit a4f808741b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java
View File

@@ -130,7 +130,7 @@ public class KubernetesInformerDiscoveryClient implements DiscoveryClient, Initi
}
V1EndpointPort port = subset.getPorts() != null && subset.getPorts().size() == 1 ? subset.getPorts().get(0)
: subset.getPorts().stream()
.filter(p -> this.properties.getPrimaryPortName().equalsIgnoreCase(p.getName())).findFirst()
.filter(p -> p.getName().equalsIgnoreCase(this.properties.getPrimaryPortName())).findFirst()
.orElseThrow(IllegalStateException::new);
List<V1EndpointAddress> addresses = subset.getAddresses();
if (this.properties.isIncludeNotReadyAddresses()