Cleanup

Author: chemicL

mcp-spring/mcp-spring-webflux/pom.xml

@@ -88,15 +88,6 @@
 			<version>${byte-buddy.version}</version>
 			<scope>test</scope>
 		</dependency>
-		<dependency>
-			<groupId>org.springframework</groupId>
-			<artifactId>spring-context</artifactId>
-			<version>6.2.6</version>
-		</dependency>
-		<dependency>
-			<groupId>io.projectreactor.netty</groupId>
-			<artifactId>reactor-netty-http</artifactId>
-		</dependency>
 		<dependency>
 			<groupId>io.projectreactor</groupId>
 			<artifactId>reactor-test</artifactId>
@@ -126,7 +117,7 @@
 			<groupId>ch.qos.logback</groupId>
 			<artifactId>logback-classic</artifactId>
 			<version>${logback.version}</version>
-<!--			<scope>test</scope>-->
+			<scope>test</scope>
 		</dependency>
 
 		<dependency>

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

@@ -3,8 +3,10 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.modelcontextprotocol.client.transport.WebClientStreamableHttpTransport;
 import io.modelcontextprotocol.spec.McpClientTransport;
+import org.junit.jupiter.api.Timeout;
 import org.springframework.web.reactive.function.client.WebClient;
 
+@Timeout(15)
 public class WebClientStreamableHttpAsyncClientResiliencyTests extends AbstractMcpAsyncClientResiliencyTests {
 
 	@Override

mcp-spring/mcp-spring-webflux/src/main/resources/logback.xml

@@ -9,13 +9,13 @@
     </appender>
 
     <!-- Main MCP package -->
-    <logger name="io.modelcontextprotocol" level="DEBUG"/>
+    <logger name="io.modelcontextprotocol" level="INFO"/>
 
     <!-- Client packages -->
-    <logger name="org.springframework.ai.mcp.client" level="DEBUG"/>
-    
+    <logger name="io.modelcontextprotocol.client" level="INFO"/>
+
     <!-- Spec package -->
-    <logger name="org.springframework.ai.mcp.spec" level="DEBUG"/>
+    <logger name="io.modelcontextprotocol.spec" level="INFO"/>
 
 
     <!-- Root logger -->

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

@@ -14,9 +14,12 @@
 import java.util.function.Supplier;
 
 import com.fasterxml.jackson.core.type.TypeReference;
-import io.modelcontextprotocol.spec.*;
+import io.modelcontextprotocol.spec.McpClientSession;
 import io.modelcontextprotocol.spec.McpClientSession.NotificationHandler;
 import io.modelcontextprotocol.spec.McpClientSession.RequestHandler;
+import io.modelcontextprotocol.spec.McpClientTransport;
+import io.modelcontextprotocol.spec.McpError;
+import io.modelcontextprotocol.spec.McpSchema;
 import io.modelcontextprotocol.spec.McpSchema.ClientCapabilities;
 import io.modelcontextprotocol.spec.McpSchema.CreateMessageRequest;
 import io.modelcontextprotocol.spec.McpSchema.CreateMessageResult;
@@ -27,6 +30,7 @@
 import io.modelcontextprotocol.spec.McpSchema.LoggingMessageNotification;
 import io.modelcontextprotocol.spec.McpSchema.PaginatedRequest;
 import io.modelcontextprotocol.spec.McpSchema.Root;
+import io.modelcontextprotocol.spec.McpSessionNotFoundException;
 import io.modelcontextprotocol.util.Assert;
 import io.modelcontextprotocol.util.Utils;
 import org.slf4j.Logger;
@@ -444,7 +448,7 @@ private <T> Mono<T> withSession(String actionName, Function<Initialization, Mono
 			Initialization previous = this.initialization.compareAndExchange(null, newInit);
 
 			boolean needsToInitialize = previous == null;
-			logger.info(needsToInitialize ? "Initialization process started" : "Joining previous initialization");
+			logger.debug(needsToInitialize ? "Initialization process started" : "Joining previous initialization");
 			if (needsToInitialize) {
 				newInit.setMcpClientSession(this.sessionSupplier.get());
 			}