Skip to content

Commit e449bd1

Browse files
committed
feat(server): Integrate McpHttpServer into SSE and streamable server startup processes
1 parent ec8afe6 commit e449bd1

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

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

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import com.github.codeboyzhou.mcp.declarative.common.GuiceInjectorModule;
44
import com.github.codeboyzhou.mcp.declarative.configuration.McpServerConfiguration;
55
import com.github.codeboyzhou.mcp.declarative.configuration.YAMLConfigurationLoader;
6+
import com.github.codeboyzhou.mcp.declarative.server.McpHttpServer;
67
import com.github.codeboyzhou.mcp.declarative.server.component.McpServerPromptFactory;
78
import com.github.codeboyzhou.mcp.declarative.server.component.McpServerResourceFactory;
89
import com.github.codeboyzhou.mcp.declarative.server.component.McpServerToolFactory;
@@ -49,12 +50,16 @@ public void startStdioServer(SimpleMcpServerBaseInfo serverInfo) {
4950
public void startSseServer(SimpleMcpHttpSseServerInfo serverInfo) {
5051
SimpleMcpHttpSseServerFactory factory = new SimpleMcpHttpSseServerFactory();
5152
McpAsyncServer server = factory.create(serverInfo);
53+
McpHttpServer httpserver = new McpHttpServer();
54+
httpserver.use(factory.transportProvider(serverInfo)).bind(serverInfo.port()).start();
5255
registerComponents(server);
5356
}
5457

5558
public void startStreamableServer(SimpleMcpHttpStreamableServerInfo serverInfo) {
5659
SimpleMcpHttpStreamableServerFactory factory = new SimpleMcpHttpStreamableServerFactory();
5760
McpAsyncServer server = factory.create(serverInfo);
61+
McpHttpServer httpserver = new McpHttpServer();
62+
httpserver.use(factory.transportProvider(serverInfo)).bind(serverInfo.port()).start();
5863
registerComponents(server);
5964
}
6065

0 commit comments

Comments
 (0)