From 4c2cd60e6e8f644778138005832ad50def976830 Mon Sep 17 00:00:00 2001 From: shunyun Date: Thu, 24 Jul 2025 11:08:05 +0800 Subject: [PATCH] Do not raise discard McpError when got unrecognized SSE event type, otherwise it will fail the MCP client function --- .../client/transport/WebFluxSseClientTransport.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java index 128cda4c3..2aba38b4b 100644 --- a/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java +++ b/mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java @@ -216,7 +216,7 @@ else if (MESSAGE_EVENT_TYPE.equals(event.event())) { } } else { - s.error(new McpError("Received unrecognized SSE event type: " + event.event())); + logger.warn("Received unrecognized SSE event type: {}", event.event()); } }).transform(handler)).subscribe(); @@ -315,9 +315,9 @@ protected Flux> eventStream() {// @formatter:off public Mono closeGracefully() { // @formatter:off return Mono.fromRunnable(() -> { isClosing = true; - + // Dispose of subscriptions - + if (inboundSubscription != null) { inboundSubscription.dispose(); }