Add sample RouterFunction
This commit is contained in:
@@ -24,6 +24,11 @@ import org.springframework.cloud.gateway.EnableGateway;
|
||||
import org.springframework.cloud.gateway.route.RouteLocator;
|
||||
import org.springframework.cloud.gateway.route.Routes;
|
||||
import org.springframework.context.annotation.Bean;
|
||||
import org.springframework.web.reactive.function.BodyInserters;
|
||||
import org.springframework.web.reactive.function.server.RequestPredicates;
|
||||
import org.springframework.web.reactive.function.server.RouterFunction;
|
||||
import org.springframework.web.reactive.function.server.RouterFunctions;
|
||||
import org.springframework.web.reactive.function.server.ServerResponse;
|
||||
|
||||
import static org.springframework.cloud.gateway.filter.factory.WebFilterFactories.addResponseHeader;
|
||||
import static org.springframework.cloud.gateway.handler.predicate.RoutePredicates.host;
|
||||
@@ -68,6 +73,14 @@ public class GatewaySampleApplication {
|
||||
return new ThrottleWebFilterFactory();
|
||||
}
|
||||
|
||||
@Bean
|
||||
public RouterFunction<ServerResponse> testFunRouterFunction() {
|
||||
RouterFunction<ServerResponse> route = RouterFunctions.route(
|
||||
RequestPredicates.path("/testfun"),
|
||||
request -> ServerResponse.ok().body(BodyInserters.fromObject("hello")));
|
||||
return route;
|
||||
}
|
||||
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(GatewaySampleApplication.class, args);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user