feat(server): Add requestTimeout field to McpServerInfo

Author: codeboyzhou

src/main/java/com/github/codeboyzhou/mcp/declarative/McpServers.java

@@ -16,16 +16,14 @@
 import io.modelcontextprotocol.spec.McpServerTransportProvider;
 import org.reflections.Reflections;
 
+import java.time.Duration;
+
 public class McpServers {
 
     private static final McpServers INSTANCE = new McpServers();
 
     private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
 
-    private static final String DEFAULT_MESSAGE_ENDPOINT = "/message";
-
-    private static final int DEFAULT_HTTP_SERVER_PORT = 8080;
-
     private static Reflections reflections;
 
     public static McpServers run(Class<?> applicationMainClass, String[] args) {
@@ -46,18 +44,20 @@ private static String determineBasePackage(McpComponentScan scan, Class<?> appli
         return applicationMainClass.getPackageName();
     }
 
+    @Deprecated(since = "0.4.0")
     public void startSyncStdioServer(String name, String version, String instructions) {
+        McpServerInfo serverInfo = McpServerInfo.builder().name(name).version(version)
+            .instructions(instructions).requestTimeout(Duration.ofSeconds(10)).build();
+        startSyncStdioServer(serverInfo);
+    }
+
+    public void startSyncStdioServer(McpServerInfo serverInfo) {
         McpServerFactory<McpSyncServer> factory = new McpSyncServerFactory();
-        McpServerInfo serverInfo = McpServerInfo.builder().name(name).version(version).instructions(instructions).build();
         McpServerTransportProvider transportProvider = new StdioServerTransportProvider();
         McpSyncServer server = factory.create(serverInfo, transportProvider);
         McpServerComponentRegisters.registerAllTo(server, reflections);
     }
 
-    public void startSyncStdioServer(McpServerInfo serverInfo) {
-        startSyncStdioServer(serverInfo.name(), serverInfo.version(), serverInfo.instructions());
-    }
-
     public void startSyncSseServer(McpSseServerInfo serverInfo, McpHttpServerStatusListener<McpSyncServer> listener) {
         McpServerFactory<McpSyncServer> factory = new McpSyncServerFactory();
         HttpServletSseServerTransportProvider transportProvider = new HttpServletSseServerTransportProvider(

src/main/java/com/github/codeboyzhou/mcp/declarative/server/McpServerInfo.java

@@ -1,5 +1,7 @@
 package com.github.codeboyzhou.mcp.declarative.server;
 
+import java.time.Duration;
+
 public class McpServerInfo {
 
     private final String name;
@@ -8,10 +10,13 @@ public class McpServerInfo {
 
     private final String instructions;
 
+    private final Duration requestTimeout;
+
     protected McpServerInfo(Builder<?> builder) {
         this.name = builder.name;
         this.version = builder.version;
         this.instructions = builder.instructions;
+        this.requestTimeout = builder.requestTimeout;
     }
 
     public static Builder<?> builder() {
@@ -30,6 +35,10 @@ public String instructions() {
         return instructions;
     }
 
+    public Duration requestTimeout() {
+        return requestTimeout;
+    }
+
     @SuppressWarnings("unchecked")
     public static class Builder<T extends Builder<T>> {
 
@@ -39,6 +48,8 @@ public static class Builder<T extends Builder<T>> {
 
         protected String instructions;
 
+        protected Duration requestTimeout;
+
         protected T self() {
             return (T) this;
         }
@@ -62,6 +73,11 @@ public T instructions(String instructions) {
             return self();
         }
 
+        public T requestTimeout(Duration requestTimeout) {
+            this.requestTimeout = requestTimeout;
+            return self();
+        }
+
     }
 
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/McpSyncServerFactory.java

@@ -12,7 +12,8 @@ public McpSyncServer create(McpServerInfo serverInfo, McpServerTransportProvider
             .instructions(serverInfo.instructions())
             .capabilities(configureServerCapabilities())
             .serverInfo(serverInfo.name(), serverInfo.version())
+            .requestTimeout(serverInfo.requestTimeout())
             .build();
     }
-    
+
 }

src/test/java/com/github/codeboyzhou/mcp/declarative/McpServersTest.java

@@ -16,6 +16,7 @@
 import org.reflections.scanners.Scanners;
 
 import java.lang.reflect.Field;
+import java.time.Duration;
 import java.util.Map;
 import java.util.Set;
 
@@ -57,6 +58,7 @@ void testStartSyncStdioServer() {
             McpServers servers = McpServers.run(TestMcpComponentScanIsNull.class, EMPTY_ARGS);
             McpServerInfo serverInfo = McpServerInfo.builder()
                 .instructions("test-mcp-sync-stdio-server-instructions")
+                .requestTimeout(Duration.ofSeconds(10))
                 .name("test-mcp-sync-stdio-server")
                 .version("1.0.0")
                 .build();
@@ -71,6 +73,7 @@ void testStartSyncSseServer() {
         assertDoesNotThrow(() -> {
             McpSseServerInfo serverInfo = McpSseServerInfo.builder()
                 .instructions("test-mcp-sync-sse-server-instructions")
+                .requestTimeout(Duration.ofSeconds(10))
                 .baseUrl("http://127.0.0.1:8080")
                 .messageEndpoint("/message")
                 .sseEndpoint("/sse")