Skip to content

Commit 5b9d662

Browse files
author
chenlinghong
committed
mcp-client: webflux support config sseEndpoint
1 parent 59ccde2 commit 5b9d662

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

auto-configurations/mcp/spring-ai-autoconfigure-mcp-client/src/main/java/org/springframework/ai/mcp/client/autoconfigure/SseWebFluxTransportAutoConfiguration.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,8 @@ public List<NamedClientMcpTransport> webFluxClientTransports(McpSseClientPropert
9090

9191
for (Map.Entry<String, SseParameters> serverParameters : sseProperties.getConnections().entrySet()) {
9292
var webClientBuilder = webClientBuilderTemplate.clone().baseUrl(serverParameters.getValue().url());
93-
var transport = new WebFluxSseClientTransport(webClientBuilder, objectMapper);
93+
var transport = new WebFluxSseClientTransport(webClientBuilder, objectMapper,
94+
serverParameters.getValue().sseEndpoint());
9495
sseTransports.add(new NamedClientMcpTransport(serverParameters.getKey(), transport));
9596
}
9697

0 commit comments

Comments
 (0)