From b53bdda23268fbfe44f776636c5aff9e5e0c30d5 Mon Sep 17 00:00:00 2001 From: Yanming Zhou Date: Tue, 5 Aug 2025 09:36:24 +0800 Subject: [PATCH] Remove duplicate header MCP_PROTOCOL_VERSION Signed-off-by: Yanming Zhou --- .../client/transport/WebClientStreamableHttpTransport.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java index 4758fd2d..6d8e82f5 100644 --- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java +++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebClientStreamableHttpTransport.java @@ -143,11 +143,8 @@ private DefaultMcpTransportSession createTransportSession() { Function> onClose = sessionId -> sessionId == null ? Mono.empty() : webClient.delete() .uri(this.endpoint) + .header(HttpHeaders.MCP_SESSION_ID, sessionId) .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() .toBodilessEntity() .onErrorComplete(e -> {