File tree Expand file tree Collapse file tree 11 files changed +21
-6
lines changed
mcp-spring-webflux/src/test/java/io/modelcontextprotocol
mcp-spring-webmvc/src/test/java/io/modelcontextprotocol/server
mcp/src/test/java/io/modelcontextprotocol Expand file tree Collapse file tree 11 files changed +21
-6
lines changed Original file line number Diff line number Diff line change 88
99import org .junit .jupiter .api .AfterEach ;
1010import org .junit .jupiter .api .BeforeEach ;
11+ import org .junit .jupiter .api .Timeout ;
1112import org .springframework .http .server .reactive .HttpHandler ;
1213import org .springframework .http .server .reactive .ReactorHttpHandlerAdapter ;
1314import org .springframework .web .reactive .function .client .WebClient ;
2627import reactor .netty .DisposableServer ;
2728import reactor .netty .http .server .HttpServer ;
2829
30+ @ Timeout (15 )
2931class WebFluxSseIntegrationTests extends AbstractMcpClientServerIntegrationTests {
3032
3133 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 88
99import org .junit .jupiter .api .AfterEach ;
1010import org .junit .jupiter .api .BeforeEach ;
11+ import org .junit .jupiter .api .Timeout ;
1112import org .springframework .http .server .reactive .HttpHandler ;
1213import org .springframework .http .server .reactive .ReactorHttpHandlerAdapter ;
1314import org .springframework .web .reactive .function .client .WebClient ;
2627import reactor .netty .DisposableServer ;
2728import reactor .netty .http .server .HttpServer ;
2829
30+ @ Timeout (15 )
2931class WebFluxStatelessIntegrationTests extends AbstractStatelessIntegrationTests {
3032
3133 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 88
99import org .junit .jupiter .api .AfterEach ;
1010import org .junit .jupiter .api .BeforeEach ;
11+ import org .junit .jupiter .api .Timeout ;
1112import org .springframework .http .server .reactive .HttpHandler ;
1213import org .springframework .http .server .reactive .ReactorHttpHandlerAdapter ;
1314import org .springframework .web .reactive .function .client .WebClient ;
2627import reactor .netty .DisposableServer ;
2728import reactor .netty .http .server .HttpServer ;
2829
30+ @ Timeout (15 )
2931class WebFluxStreamableIntegrationTests extends AbstractMcpClientServerIntegrationTests {
3032
3133 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 3737import reactor .test .StepVerifier ;
3838
3939/**
40- * Fixed version of tests for error handling in WebClientStreamableHttpTransport.
41- * Addresses concurrency issues with proper Reactor patterns.
40+ * Tests for error handling in WebClientStreamableHttpTransport. Addresses concurrency
41+ * issues with proper Reactor patterns.
4242 *
4343 * @author Christian Tzolov
4444 */
Original file line number Diff line number Diff line change 1111import org .apache .catalina .LifecycleState ;
1212import org .junit .jupiter .api .AfterEach ;
1313import org .junit .jupiter .api .BeforeEach ;
14+ import org .junit .jupiter .api .Timeout ;
1415import org .springframework .context .annotation .Bean ;
1516import org .springframework .context .annotation .Configuration ;
1617import org .springframework .web .reactive .function .client .WebClient ;
2930import io .modelcontextprotocol .server .transport .WebMvcSseServerTransportProvider ;
3031import reactor .core .scheduler .Schedulers ;
3132
33+ @ Timeout (15 )
3234class WebMvcSseIntegrationTests extends AbstractMcpClientServerIntegrationTests {
3335
3436 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 1111import org .apache .catalina .LifecycleState ;
1212import org .junit .jupiter .api .AfterEach ;
1313import org .junit .jupiter .api .BeforeEach ;
14+ import org .junit .jupiter .api .Timeout ;
1415import org .springframework .context .annotation .Bean ;
1516import org .springframework .context .annotation .Configuration ;
1617import org .springframework .web .reactive .function .client .WebClient ;
2930import io .modelcontextprotocol .server .transport .WebMvcStatelessServerTransport ;
3031import reactor .core .scheduler .Schedulers ;
3132
33+ @ Timeout (15 )
3234class WebMvcStatelessIntegrationTests extends AbstractStatelessIntegrationTests {
3335
3436 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 1111import org .apache .catalina .LifecycleState ;
1212import org .junit .jupiter .api .AfterEach ;
1313import org .junit .jupiter .api .BeforeEach ;
14- import org .junit .jupiter .params .ParameterizedTest ;
15- import org .junit .jupiter .params .provider .ValueSource ;
14+ import org .junit .jupiter .api .Timeout ;
1615import org .springframework .context .annotation .Bean ;
1716import org .springframework .context .annotation .Configuration ;
1817import org .springframework .web .reactive .function .client .WebClient ;
2928import io .modelcontextprotocol .server .McpServer .AsyncSpecification ;
3029import io .modelcontextprotocol .server .McpServer .SyncSpecification ;
3130import io .modelcontextprotocol .server .transport .WebMvcStreamableServerTransportProvider ;
32- import io .modelcontextprotocol .spec .McpSchema ;
3331import reactor .core .scheduler .Schedulers ;
3432
33+ @ Timeout (15 )
3534class WebMvcStreamableIntegrationTests extends AbstractMcpClientServerIntegrationTests {
3635
3736 private static final int PORT = TestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 3737 *
3838 * @author Christian Tzolov
3939 */
40- @ Timeout (5 )
40+ @ Timeout (15 )
4141public class HttpClientStreamableHttpTransportErrorHandlingTest {
4242
4343 private static final int PORT = TomcatTestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 1313import org .apache .catalina .startup .Tomcat ;
1414import org .junit .jupiter .api .AfterEach ;
1515import org .junit .jupiter .api .BeforeEach ;
16+ import org .junit .jupiter .api .Timeout ;
1617
1718import com .fasterxml .jackson .databind .ObjectMapper ;
1819
2324import io .modelcontextprotocol .server .transport .HttpServletSseServerTransportProvider ;
2425import io .modelcontextprotocol .server .transport .TomcatTestUtil ;
2526
27+ @ Timeout (15 )
2628class HttpServletSseIntegrationTests extends AbstractMcpClientServerIntegrationTests {
2729
2830 private static final int PORT = TomcatTestUtil .findAvailablePort ();
Original file line number Diff line number Diff line change 2929import org .junit .jupiter .api .AfterEach ;
3030import org .junit .jupiter .api .BeforeEach ;
3131import org .junit .jupiter .api .Test ;
32+ import org .junit .jupiter .api .Timeout ;
3233import org .junit .jupiter .params .ParameterizedTest ;
3334import org .junit .jupiter .params .provider .ValueSource ;
3435import org .springframework .mock .web .MockHttpServletRequest ;
4950import static org .assertj .core .api .Assertions .assertThat ;
5051import static org .awaitility .Awaitility .await ;
5152
53+ @ Timeout (15 )
5254class HttpServletStatelessIntegrationTests {
5355
5456 private static final int PORT = TomcatTestUtil .findAvailablePort ();
You can’t perform that action at this time.
0 commit comments