feat: add WebMvcSseServerTransportProvider implementation

This commit introduces WebMvcSseServerTransportProvider as a replacement for the now-deprecated WebMvcSseServerTransport.
The new provider-based implementation offers improved session management and better alignment with the MCP specification.

Additional changes:

- Deprecate WebMvcSseServerTransport and StdioServerTransport
- Add corresponding deprecated test classes to maintain backward compatibility
- Increase test timeouts from 300ms to 1000ms/2000ms for more reliable testing
- Minor rename of ClientMcpTransport to McpClientTransport for naming consistency

Signed-off-by: Christian Tzolov <[email protected]>

Author: tzolov

mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/client/transport/WebFluxSseClientTransport.java

@@ -9,7 +9,7 @@
 
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import io.modelcontextprotocol.spec.ClientMcpTransport;
+import io.modelcontextprotocol.spec.McpClientTransport;
 import io.modelcontextprotocol.spec.McpError;
 import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpSchema.JSONRPCMessage;
@@ -58,7 +58,7 @@
  * "https://spec.modelcontextprotocol.io/specification/basic/transports/#http-with-sse">MCP
  * HTTP with SSE Transport Specification</a>
  */
-public class WebFluxSseClientTransport implements ClientMcpTransport {
+public class WebFluxSseClientTransport implements McpClientTransport {
 
 	private static final Logger logger = LoggerFactory.getLogger(WebFluxSseClientTransport.class);
 

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/client/WebFluxSseMcpAsyncClientTests.java

@@ -7,7 +7,7 @@
 import java.time.Duration;
 
 import io.modelcontextprotocol.client.transport.WebFluxSseClientTransport;
-import io.modelcontextprotocol.spec.ClientMcpTransport;
+import io.modelcontextprotocol.spec.McpClientTransport;
 import org.junit.jupiter.api.Timeout;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
@@ -32,7 +32,7 @@ class WebFluxSseMcpAsyncClientTests extends AbstractMcpAsyncClientTests {
 		.waitingFor(Wait.forHttp("/").forStatusCode(404));
 
 	@Override
-	protected ClientMcpTransport createMcpTransport() {
+	protected McpClientTransport createMcpTransport() {
 		return new WebFluxSseClientTransport(WebClient.builder().baseUrl(host));
 	}
 
@@ -50,7 +50,7 @@ public void onClose() {
 
 	@Override
 	protected Duration getTimeoutDuration() {
-		return Duration.ofMillis(300);
+		return Duration.ofMillis(1000);
 	}
 
 }

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/client/WebFluxSseMcpSyncClientTests.java

@@ -7,7 +7,7 @@
 import java.time.Duration;
 
 import io.modelcontextprotocol.client.transport.WebFluxSseClientTransport;
-import io.modelcontextprotocol.spec.ClientMcpTransport;
+import io.modelcontextprotocol.spec.McpClientTransport;
 import org.junit.jupiter.api.Timeout;
 import org.testcontainers.containers.GenericContainer;
 import org.testcontainers.containers.wait.strategy.Wait;
@@ -32,7 +32,7 @@ class WebFluxSseMcpSyncClientTests extends AbstractMcpSyncClientTests {
 		.waitingFor(Wait.forHttp("/").forStatusCode(404));
 
 	@Override
-	protected ClientMcpTransport createMcpTransport() {
+	protected McpClientTransport createMcpTransport() {
 		return new WebFluxSseClientTransport(WebClient.builder().baseUrl(host));
 	}
 
@@ -50,7 +50,7 @@ protected void onClose() {
 
 	@Override
 	protected Duration getTimeoutDuration() {
-		return Duration.ofMillis(300);
+		return Duration.ofMillis(1000);
 	}
 
 }

mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcSseServerTransport.java

@@ -33,6 +33,9 @@
  * a bridge between synchronous WebMVC operations and reactive programming patterns to
  * maintain compatibility with the reactive transport interface.
  *
+ * @deprecated This class will be removed in 0.9.0. Use
+ * {@link WebMvcSseServerTransportProvider}.
+ *
  * <p>
  * Key features:
  * <ul>
@@ -57,12 +60,12 @@
  * This implementation uses {@link ConcurrentHashMap} to safely manage multiple client
  * sessions in a thread-safe manner. Each client session is assigned a unique ID and
  * maintains its own SSE connection.
- *
  * @author Christian Tzolov
  * @author Alexandros Pappas
  * @see ServerMcpTransport
  * @see RouterFunction
  */
+@Deprecated
 public class WebMvcSseServerTransport implements ServerMcpTransport {
 
 	private static final Logger logger = LoggerFactory.getLogger(WebMvcSseServerTransport.class);