diff --git a/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java b/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java index 99cf2a625..4526734d2 100644 --- a/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java +++ b/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java @@ -404,6 +404,7 @@ public Mono sendMessage(JSONRPCMessage message) { } } catch (InterruptedException e) { + Thread.currentThread().interrupt(); // Preserve interrupt status return Mono.error(new McpError("Failed to wait for the message endpoint")); }