From d70a81ee43d374fcc94cd81e77482bafd485ddb5 Mon Sep 17 00:00:00 2001 From: jade Date: Wed, 15 Jul 2026 23:10:32 +0900 Subject: [PATCH] fix: ensure ssePath for common uses /mcp/sse/common --- .../biz/mcp/gateway/sync/DynamicMcpServerManager.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/axhub-gateway/src/main/java/io/shinhanlife/axhub/biz/mcp/gateway/sync/DynamicMcpServerManager.java b/axhub-gateway/src/main/java/io/shinhanlife/axhub/biz/mcp/gateway/sync/DynamicMcpServerManager.java index d0fd0bd..fffbd85 100644 --- a/axhub-gateway/src/main/java/io/shinhanlife/axhub/biz/mcp/gateway/sync/DynamicMcpServerManager.java +++ b/axhub-gateway/src/main/java/io/shinhanlife/axhub/biz/mcp/gateway/sync/DynamicMcpServerManager.java @@ -61,8 +61,8 @@ public class DynamicMcpServerManager { return categoryServers.computeIfAbsent(safeCategory, key -> { log.info("Creating dynamic MCP Server for category: {}", key); - String ssePath = "common".equals(key) ? "/mcp/sse" : "/mcp/sse/" + key; - String msgPath = "common".equals(key) ? "/mcp/message" : "/mcp/message/" + key; + String ssePath = "/mcp/sse/" + key; + String msgPath = "/mcp/message/" + key; WebMvcSseServerTransportProvider transport = WebMvcSseServerTransportProvider.builder() .sseEndpoint(ssePath) @@ -116,12 +116,16 @@ public class DynamicMcpServerManager { public RouterFunction getDynamicRouter() { return request -> { - for (WebMvcSseServerTransportProvider transport : categoryTransports.values()) { + log.info("[DynamicMcpRouter] Incoming request path: {}, method: {}", request.path(), request.method()); + for (Map.Entry entry : categoryTransports.entrySet()) { + WebMvcSseServerTransportProvider transport = entry.getValue(); Optional> handler = transport.getRouterFunction().route(request); if (handler.isPresent()) { + log.info("[DynamicMcpRouter] Matched handler for key: {}", entry.getKey()); return handler; } } + log.info("[DynamicMcpRouter] No handler matched for path: {}", request.path()); return Optional.empty(); }; }