Skip to content

Commit 1dbfedb

Browse files
committed
fix test
Signed-off-by: wind57 <[email protected]>
1 parent a051455 commit 1dbfedb

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesClientInformerReactiveDiscoveryClientAutoConfiguration.java

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -77,6 +77,7 @@ KubernetesClientInformerReactiveDiscoveryClient kubernetesClientReactiveDiscover
7777
KubernetesClientInformerDiscoveryClient blockingClient = new KubernetesClientInformerDiscoveryClient(
7878
sharedInformerFactories, serviceListers, endpointsListers, serviceInformers, endpointsInformers,
7979
properties, coreV1Api, predicate);
80+
blockingClient.afterPropertiesSet();
8081

8182
return new KubernetesClientInformerReactiveDiscoveryClient(blockingClient);
8283
}
@@ -104,6 +105,7 @@ KubernetesClientCacheableInformerReactiveDiscoveryClient kubernetesClientCacheab
104105
KubernetesClientInformerDiscoveryClient blockingClient = new KubernetesClientInformerDiscoveryClient(
105106
sharedInformerFactories, serviceListers, endpointsListers, serviceInformers, endpointsInformers,
106107
properties, coreV1Api, predicate);
108+
blockingClient.afterPropertiesSet();
107109

108110
return new KubernetesClientCacheableInformerReactiveDiscoveryClient(blockingClient);
109111
}
@@ -121,6 +123,7 @@ ReactiveDiscoveryClientHealthIndicator reactiveDiscoveryClientHealthIndicator(
121123
KubernetesClientInformerDiscoveryClient blockingClient = new KubernetesClientInformerDiscoveryClient(
122124
sharedInformerFactories, serviceListers, endpointsListers, serviceInformers, endpointsInformers,
123125
kubernetesDiscoveryProperties, coreV1Api, predicate);
126+
blockingClient.afterPropertiesSet();
124127

125128
KubernetesClientInformerReactiveDiscoveryClient reactiveClient = new KubernetesClientInformerReactiveDiscoveryClient(
126129
blockingClient);
@@ -130,11 +133,10 @@ ReactiveDiscoveryClientHealthIndicator reactiveDiscoveryClientHealthIndicator(
130133

131134
// Above two beans are created when cacheable is enabled. In this case, we can't make
132135
// KubernetesClientInformerDiscoveryClient a @Bean, since blocking discovery might be
133-
// disabled and we do
134-
// not want to allow wiring of it. Nevertheless, we still need an instance of
135-
// KubernetesClientInformerDiscoveryClient
136+
// disabled and we do not want to allow wiring of it.
137+
// Nevertheless, we still need an instance of KubernetesClientInformerDiscoveryClient
136138
// in order to create the ReactiveDiscoveryClientHealthIndicator and
137-
// KubernetesClientCacheableInformerReactiveDiscoveryClient
139+
// KubernetesClientCacheableInformerReactiveDiscoveryClient.
138140
// As such, we create two of such instances in each bean.
139141

140142
/**

0 commit comments

Comments
 (0)