feat(test): adds findAvailablePort for test server...

Author: Aliaksie

…odelcontextprotocol/server/TestUtil.java …va/io/modelcontextprotocol/TestUtil.javamcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/server/TestUtil.java renamed to mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/TestUtil.java mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/server/TestUtil.java renamed to mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/TestUtil.java

@@ -1,7 +1,7 @@
 /*
 * Copyright 2025 - 2025 the original author or authors.
 */
-package io.modelcontextprotocol.server;
+package io.modelcontextprotocol;
 
 import java.io.IOException;
 import java.net.InetSocketAddress;

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/WebFluxSseIntegrationTests.java

@@ -48,9 +48,9 @@
 import static org.awaitility.Awaitility.await;
 import static org.mockito.Mockito.mock;
 
-public class WebFluxSseIntegrationTests {
+class WebFluxSseIntegrationTests {
 
-	private static final int PORT = 8182;
+	private static final int PORT = TestUtil.findAvailablePort();
 
 	private static final String CUSTOM_SSE_ENDPOINT = "/somePath/sse";
 
@@ -129,7 +129,7 @@ void testCreateMessageWithoutSamplingCapabilities(String clientType) {
 
 	@ParameterizedTest(name = "{0} : {displayName} ")
 	@ValueSource(strings = { "httpclient", "webflux" })
-	void testCreateMessageSuccess(String clientType) throws InterruptedException {
+	void testCreateMessageSuccess(String clientType) {
 
 		// Client
 		var clientBuilder = clientBuilders.get(clientType);
@@ -188,8 +188,7 @@ void testCreateMessageSuccess(String clientType) throws InterruptedException {
 
 		CallToolResult response = mcpClient.callTool(new McpSchema.CallToolRequest("tool1", Map.of()));
 
-		assertThat(response).isNotNull();
-		assertThat(response).isEqualTo(callResponse);
+		assertThat(response).isNotNull().isEqualTo(callResponse);
 
 		mcpClient.close();
 		mcpServer.close();
@@ -417,8 +416,7 @@ void testToolCallSuccess(String clientType) {
 
 		CallToolResult response = mcpClient.callTool(new McpSchema.CallToolRequest("tool1", Map.of()));
 
-		assertThat(response).isNotNull();
-		assertThat(response).isEqualTo(callResponse);
+		assertThat(response).isNotNull().isEqualTo(callResponse);
 
 		mcpClient.close();
 		mcpServer.close();

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/server/WebFluxSseMcpAsyncServerTests.java

@@ -5,6 +5,8 @@
 package io.modelcontextprotocol.server;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+
+import io.modelcontextprotocol.TestUtil;
 import io.modelcontextprotocol.server.transport.WebFluxSseServerTransportProvider;
 import io.modelcontextprotocol.spec.McpServerTransportProvider;
 import org.junit.jupiter.api.Timeout;

mcp-spring/mcp-spring-webflux/src/test/java/io/modelcontextprotocol/server/WebFluxSseMcpSyncServerTests.java

@@ -5,6 +5,8 @@
 package io.modelcontextprotocol.server;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
+
+import io.modelcontextprotocol.TestUtil;
 import io.modelcontextprotocol.server.transport.WebFluxSseServerTransportProvider;
 import io.modelcontextprotocol.spec.McpServerTransportProvider;
 import org.junit.jupiter.api.Timeout;