From 2948465b8a6265d12b75ca3d395dc4bcbbcc5552 Mon Sep 17 00:00:00 2001 From: kimhyungsik Date: Thu, 23 Jul 2026 10:15:56 +0900 Subject: [PATCH] fix: comment out emitter.complete() to allow keep-alive sessions for standard SSE MCP client --- .../dapms/sync/CustomWebMvcSseServerTransportProvider.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/dap-gateway/src/main/java/io/shinhanlife/dap/dapms/sync/CustomWebMvcSseServerTransportProvider.java b/dap-gateway/src/main/java/io/shinhanlife/dap/dapms/sync/CustomWebMvcSseServerTransportProvider.java index f95bf50..f89866d 100644 --- a/dap-gateway/src/main/java/io/shinhanlife/dap/dapms/sync/CustomWebMvcSseServerTransportProvider.java +++ b/dap-gateway/src/main/java/io/shinhanlife/dap/dapms/sync/CustomWebMvcSseServerTransportProvider.java @@ -179,8 +179,8 @@ public class CustomWebMvcSseServerTransportProvider implements McpServerTranspor log.info("Message sent to session handler"); if (emitter != null && !map.containsKey("id")) { - emitter.complete(); - log.info("Completed emitter for notification"); + // emitter.complete(); + log.info("Completed emitter for notification (disabled for keep-alive)"); } return ResponseEntity.ok().build(); @@ -220,7 +220,7 @@ public class CustomWebMvcSseServerTransportProvider implements McpServerTranspor // Custom 프로토콜: 1회 요청당 1응답 후 종료 (스트림을 닫아버림) // 클라이언트가 한 번의 POST 후 응답을 받고 연결을 끊기 때문 - this.emitter.complete(); + // this.emitter.complete(); } } catch (Exception e) { log.error("Error sending message to SSE emitter", e);