Skip to content

Commit 4e313a9

Browse files
LiujunjieALilingtzolov
authored andcommitted
feat(mcp): Add SSE endpoint parameter to WebFlux and WebMvc transport providers
Add serverProperties.getSseEndpoint() parameter to both WebFluxSseServerTransportProvider and WebMvcSseServerTransportProvider constructors. Signed-off-by: liujunjie <[email protected]>
1 parent 25e52b8 commit 4e313a9

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server/src/main/java/org/springframework/ai/mcp/server/autoconfigure/McpWebFluxServerAutoConfiguration.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,8 @@ public class McpWebFluxServerAutoConfiguration {
7777
public WebFluxSseServerTransportProvider webFluxTransport(ObjectProvider<ObjectMapper> objectMapperProvider,
7878
McpServerProperties serverProperties) {
7979
ObjectMapper objectMapper = objectMapperProvider.getIfAvailable(ObjectMapper::new);
80-
return new WebFluxSseServerTransportProvider(objectMapper, serverProperties.getSseMessageEndpoint());
80+
return new WebFluxSseServerTransportProvider(objectMapper, serverProperties.getSseMessageEndpoint(),
81+
serverProperties.getSseEndpoint());
8182
}
8283

8384
// Router function for SSE transport used by Spring WebFlux to start an HTTP server.

auto-configurations/mcp/spring-ai-autoconfigure-mcp-server/src/main/java/org/springframework/ai/mcp/server/autoconfigure/McpWebMvcServerAutoConfiguration.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,8 @@ public class McpWebMvcServerAutoConfiguration {
7272
public WebMvcSseServerTransportProvider webMvcSseServerTransportProvider(
7373
ObjectProvider<ObjectMapper> objectMapperProvider, McpServerProperties serverProperties) {
7474
ObjectMapper objectMapper = objectMapperProvider.getIfAvailable(ObjectMapper::new);
75-
return new WebMvcSseServerTransportProvider(objectMapper, serverProperties.getSseMessageEndpoint());
75+
return new WebMvcSseServerTransportProvider(objectMapper, serverProperties.getSseMessageEndpoint(),
76+
serverProperties.getSseEndpoint());
7677
}
7778

7879
@Bean

0 commit comments

Comments
 (0)