modelcontextprotocol/java-sdk
Watch
1
0
Fork
You've already forked java-sdk
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Remove duplicate header MCP_PROTOCOL_VERSION

Browse source 
Signed-off-by: Yanming Zhou <zhouyanming@gmail.com>
This commit is contained in:
Yanming Zhou 2025-08-05 09:36:24 +08:00 • committed by Christian Tzolov
commit 69cf41b12f
1 changed files with 1 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

5
mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java
View file

@ -143,11 +143,8 @@ public class WebClientStreamableHttpTransport implements McpClientTransport {
Function<String, Publisher<Void>> onClose = sessionId -> sessionId == null ? Mono.empty() Function<String, Publisher<Void>> onClose = sessionId -> sessionId == null ? Mono.empty()
: webClient.delete() : webClient.delete()
.uri(this.endpoint) .uri(this.endpoint)
.header(HttpHeaders.MCP_SESSION_ID, sessionId)
.header(HttpHeaders.PROTOCOL_VERSION, MCP_PROTOCOL_VERSION) .header(HttpHeaders.PROTOCOL_VERSION, MCP_PROTOCOL_VERSION)
.headers(httpHeaders -> {
httpHeaders.add(HttpHeaders.MCP_SESSION_ID, sessionId);
httpHeaders.add(HttpHeaders.PROTOCOL_VERSION, MCP_PROTOCOL_VERSION);
})
.retrieve() .retrieve()
.toBodilessEntity() .toBodilessEntity()
.onErrorComplete(e -> { .onErrorComplete(e -> {