feat(configuration): Add streamable configuration support

Author: codeboyzhou

src/main/java/com/github/codeboyzhou/mcp/declarative/configuration/McpServerConfiguration.java

@@ -15,4 +15,5 @@ public record McpServerConfiguration(
     @JsonProperty("request-timeout") long requestTimeout,
     @JsonProperty("capabilities") McpServerCapabilities capabilities,
     @JsonProperty("change-notification") McpServerChangeNotification changeNotification,
-    @JsonProperty("sse") McpServerSSE sse) {}
+    @JsonProperty("sse") McpServerSSE sse,
+    @JsonProperty("streamable") McpServerStreamable streamable) {}

src/main/java/com/github/codeboyzhou/mcp/declarative/configuration/McpServerStreamable.java

@@ -0,0 +1,9 @@
+package com.github.codeboyzhou.mcp.declarative.configuration;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public record McpServerStreamable(
+    @JsonProperty("mcp-endpoint") String mcpEndpoint,
+    @JsonProperty("disallow-delete") boolean disallowDelete,
+    @JsonProperty("keep-alive-interval") long keepAliveInterval,
+    @JsonProperty("port") int port) {}

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/McpSseServerFactory.java

@@ -13,7 +13,8 @@ public McpServer.SyncSpecification<?> sync(McpSseServerInfo info) {
             .sseEndpoint(info.sseEndpoint())
             .messageEndpoint(info.messageEndpoint())
             .build();
-    threadPool.execute(() -> new McpHttpServer().use(transportProvider).bind(info.port()).start());
+    McpHttpServer httpserver = new McpHttpServer();
+    threadPool.execute(() -> httpserver.use(transportProvider).bind(info.port()).start());
     return McpServer.sync(transportProvider);
   }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/McpStreamableServerFactory.java

@@ -16,7 +16,8 @@ public McpServer.SyncSpecification<?> sync(McpStreamableServerInfo info) {
             .contextExtractor(info.contextExtractor())
             .keepAliveInterval(info.keepAliveInterval())
             .build();
-    threadPool.execute(() -> new McpHttpServer().use(transportProvider).bind(info.port()).start());
+    McpHttpServer httpserver = new McpHttpServer();
+    threadPool.execute(() -> httpserver.use(transportProvider).bind(info.port()).start());
     return McpServer.sync(transportProvider);
   }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/configurable/ConfigurableMcpSseServerFactory.java

@@ -21,7 +21,8 @@ public McpServer.SyncSpecification<?> specification() {
             .sseEndpoint(sse.endpoint())
             .messageEndpoint(sse.messageEndpoint())
             .build();
-    threadPool.execute(() -> new McpHttpServer().use(transportProvider).bind(sse.port()).start());
+    McpHttpServer httpserver = new McpHttpServer();
+    threadPool.execute(() -> httpserver.use(transportProvider).bind(sse.port()).start());
     return McpServer.sync(transportProvider);
   }
 }

src/main/java/com/github/codeboyzhou/mcp/declarative/server/factory/configurable/ConfigurableMcpStreamableServerFactory.java

@@ -1,10 +1,12 @@
 package com.github.codeboyzhou.mcp.declarative.server.factory.configurable;
 
 import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
+import com.github.codeboyzhou.mcp.declarative.configuration.McpServerStreamable;
 import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
 import com.github.codeboyzhou.mcp.declarative.util.ObjectMappers;
 import io.modelcontextprotocol.server.McpServer;
 import io.modelcontextprotocol.server.transport.HttpServletStreamableServerTransportProvider;
+import java.time.Duration;
 
 public class ConfigurableMcpStreamableServerFactory extends AbstractConfigurableMcpServerFactory {
 
@@ -14,11 +16,16 @@ public ConfigurableMcpStreamableServerFactory(McpServerConfiguration configurati
 
   @Override
   public McpServer.SyncSpecification<?> specification() {
+    McpServerStreamable streamable = configuration.streamable();
     HttpServletStreamableServerTransportProvider transportProvider =
         HttpServletStreamableServerTransportProvider.builder()
             .objectMapper(ObjectMappers.JSON_MAPPER)
+            .mcpEndpoint(streamable.mcpEndpoint())
+            .disallowDelete(streamable.disallowDelete())
+            .keepAliveInterval(Duration.ofMillis(streamable.keepAliveInterval()))
             .build();
-    threadPool.execute(() -> new McpHttpServer().use(transportProvider).bind(8080).start());
+    McpHttpServer httpserver = new McpHttpServer();
+    threadPool.execute(() -> httpserver.use(transportProvider).bind(streamable.port()).start());
     return McpServer.sync(transportProvider);
   }
 }

src/test/resources/mcp-server.yml

@@ -12,8 +12,8 @@ change-notification:
   resource: true
   prompt: true
   tool: true
-sse:
-  message-endpoint: /mcp/message
-  endpoint: /sse
-  base-url: http://localhost:8080
+streamable:
+  mcp-endpoint: /mcp/message
+  disallow-delete: true
+  keep-alive-interval: 30000
   port: 8080

src/test/resources/test-mcp-server-enable-streamable-http-mode.yml

@@ -12,8 +12,8 @@ change-notification:
   resource: true
   prompt: true
   tool: true
-sse:
-  message-endpoint: /mcp/message
-  endpoint: /sse
-  base-url: http://localhost:8080
+streamable:
+  mcp-endpoint: /mcp/message
+  disallow-delete: true
+  keep-alive-interval: 30000
   port: 8080