diff --git a/mcp-spring/mcp-spring-webflux/README.md b/mcp-spring/mcp-spring-webflux/README.md index e701e41e6..ff765d74a 100644 --- a/mcp-spring/mcp-spring-webflux/README.md +++ b/mcp-spring/mcp-spring-webflux/README.md @@ -22,7 +22,7 @@ static class MyConfig { // Router function for SSE transport used by Spring WebFlux to start an HTTP // server. @Bean - public RouterFunction mcpRouterFunction(WebFluxSseServerTransport transport) { + public RouterFunction mcpRouterFunction(WebFluxSseServerTransport transport) { return transport.getRouterFunction(); } diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java index 95355c0f2..4bb72235e 100644 --- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java +++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java @@ -109,7 +109,7 @@ public class WebFluxSseServerTransportProvider implements McpServerTransportProv private final String sseEndpoint; - private final RouterFunction routerFunction; + private final RouterFunction routerFunction; private McpServerSession.Factory sessionFactory; @@ -256,7 +256,7 @@ public Mono closeGracefully() { * * @return The configured {@link RouterFunction} for handling HTTP requests */ - public RouterFunction getRouterFunction() { + public RouterFunction getRouterFunction() { return this.routerFunction; } diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStatelessServerTransport.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStatelessServerTransport.java index 400be341e..3371115f8 100644 --- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStatelessServerTransport.java +++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStatelessServerTransport.java @@ -38,7 +38,7 @@ public class WebFluxStatelessServerTransport implements McpStatelessServerTransp private final String mcpEndpoint; - private final RouterFunction routerFunction; + private final RouterFunction routerFunction; private McpStatelessServerHandler mcpHandler; @@ -83,7 +83,7 @@ public Mono closeGracefully() { * * @return The configured {@link RouterFunction} for handling HTTP requests */ - public RouterFunction getRouterFunction() { + public RouterFunction getRouterFunction() { return this.routerFunction; } diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStreamableServerTransportProvider.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStreamableServerTransportProvider.java index 144a3ce02..1c47c51e1 100644 --- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStreamableServerTransportProvider.java +++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxStreamableServerTransportProvider.java @@ -55,7 +55,7 @@ public class WebFluxStreamableServerTransportProvider implements McpStreamableSe private final boolean disallowDelete; - private final RouterFunction routerFunction; + private final RouterFunction routerFunction; private McpStreamableServerSession.Factory sessionFactory; @@ -152,7 +152,7 @@ public Mono closeGracefully() { * * @return The configured {@link RouterFunction} for handling HTTP requests */ - public RouterFunction getRouterFunction() { + public RouterFunction getRouterFunction() { return this.routerFunction; }