From f7f1a9f472c539c66eb9cecb962a2fe73f7cd784 Mon Sep 17 00:00:00 2001 From: Spencer Gibb Date: Fri, 27 Jan 2017 17:15:57 -0700 Subject: [PATCH] Wire CompositeRouteReader --- .../gateway/test/GatewayTestApplication.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/src/test/java/org/springframework/cloud/gateway/test/GatewayTestApplication.java b/src/test/java/org/springframework/cloud/gateway/test/GatewayTestApplication.java index 680e0246..595e170a 100644 --- a/src/test/java/org/springframework/cloud/gateway/test/GatewayTestApplication.java +++ b/src/test/java/org/springframework/cloud/gateway/test/GatewayTestApplication.java @@ -5,11 +5,17 @@ import org.springframework.boot.SpringBootConfiguration; import org.springframework.boot.autoconfigure.EnableAutoConfiguration; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; +import org.springframework.cloud.gateway.api.CompositeRouteReader; +import org.springframework.cloud.gateway.config.GatewayProperties; +import org.springframework.cloud.gateway.config.PropertiesRouteReader; import org.springframework.cloud.gateway.discovery.DiscoveryClientRouteReader; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Primary; import org.springframework.context.annotation.Profile; +import reactor.core.publisher.Flux; + @SpringBootConfiguration @EnableAutoConfiguration public class GatewayTestApplication { @@ -28,6 +34,18 @@ public class GatewayTestApplication { public DiscoveryClientRouteReader discoveryClientRouteReader(DiscoveryClient discoveryClient) { return new DiscoveryClientRouteReader(discoveryClient); } + + @Bean + public PropertiesRouteReader propertiesRouteReader(GatewayProperties properties) { + return new PropertiesRouteReader(properties); + } + + @Bean + @Primary + public CompositeRouteReader compositeRouteReader(DiscoveryClientRouteReader discoveryClientRouteReader, + PropertiesRouteReader propertiesRouteReader) { + return new CompositeRouteReader(Flux.just(discoveryClientRouteReader, propertiesRouteReader)); + } } public static void main(String[] args) {