From d5592f9f9c55622a8f7e7a8fe109281a0918ecd4 Mon Sep 17 00:00:00 2001 From: piomin Date: Mon, 24 Aug 2020 13:59:08 +0200 Subject: [PATCH] #962 Fixing tests dependent to KubernetesServiceInstance --- .../HttpBasedConfigurationWatchChangeDetectorTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/HttpBasedConfigurationWatchChangeDetectorTests.java b/spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/HttpBasedConfigurationWatchChangeDetectorTests.java index 3636bbca..cd42b5b8 100644 --- a/spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/HttpBasedConfigurationWatchChangeDetectorTests.java +++ b/spring-cloud-kubernetes-controllers/spring-cloud-kubernetes-configuration-watcher/src/test/java/org/springframework/cloud/kubernetes/configuration/watcher/HttpBasedConfigurationWatchChangeDetectorTests.java @@ -99,7 +99,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests { fooEndpointPort.setPort(wireMockRule.port()); List instances = new ArrayList<>(); KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance( - "foo", "foo", fooEndpointAddress, fooEndpointPort, new HashMap<>(), + "foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), new HashMap<>(), false); instances.add(fooServiceInstance); when(reactiveDiscoveryClient.getInstances(eq("foo"))) @@ -185,7 +185,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests { fooEndpointPort.setPort(wireMockRule.port()); List instances = new ArrayList<>(); KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance( - "foo", "foo", fooEndpointAddress, fooEndpointPort, metadata, false); + "foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), metadata, false); instances.add(fooServiceInstance); when(reactiveDiscoveryClient.getInstances(eq("foo"))) .thenReturn(Flux.fromIterable(instances)); @@ -211,7 +211,7 @@ public class HttpBasedConfigurationWatchChangeDetectorTests { fooEndpointPort.setPort(wireMockRule.port()); List instances = new ArrayList<>(); KubernetesServiceInstance fooServiceInstance = new KubernetesServiceInstance( - "foo", "foo", fooEndpointAddress, fooEndpointPort, metadata, false); + "foo", "foo", fooEndpointAddress.getIp(), fooEndpointPort.getPort(), metadata, false); instances.add(fooServiceInstance); when(reactiveDiscoveryClient.getInstances(eq("foo"))) .thenReturn(Flux.fromIterable(instances));