diff --git a/mcp-core/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java b/mcp-core/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java index 29dc23c35..234b8477a 100644 --- a/mcp-core/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java +++ b/mcp-core/src/main/java/io/modelcontextprotocol/client/transport/ResponseSubscribers.java @@ -179,6 +179,11 @@ else if (line.startsWith(":")) { logger.debug("Ignoring comment line: {}", line); upstream().request(1); } + else if (line.startsWith("retry:")) { + // Ignore SSE retry directive — only the server controls reconnection + logger.debug("Ignoring retry directive: {}", line); + upstream().request(1); + } else { // If the response is not successful, emit an error this.sink.error(new McpTransportException(