From c9590a2c9699169ed825c9453445ecf97ac7370e Mon Sep 17 00:00:00 2001 From: Yanming Zhou Date: Thu, 16 Oct 2025 16:57:43 +0800 Subject: [PATCH] Polish webflux server transports Use `RouterFunction` instead of `RouterFunction` to align with webmvc server transports Signed-off-by: Yanming Zhou --- mcp-spring/mcp-spring-webflux/README.md | 2 +- .../server/transport/WebFluxSseServerTransportProvider.java | 4 ++-- .../server/transport/WebFluxStatelessServerTransport.java | 4 ++-- .../transport/WebFluxStreamableServerTransportProvider.java | 4 ++-- 4 files changed, 7 insertions(+), 7 deletions(-) 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; }