Skip to content

Commit dd775a0

Browse files
committed
fix close_wait and tomcat connection keeps growing
1 parent 082444e commit dd775a0

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

mcp-spring/mcp-spring-webmvc/src/main/java/io/modelcontextprotocol/server/transport/WebMvcSseServerTransportProvider.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -263,10 +263,13 @@ private ServerResponse handleSseConnection(ServerRequest request) {
263263
logger.debug("Creating new SSE connection for session: {}", sessionId);
264264
sseBuilder.onComplete(() -> {
265265
logger.debug("SSE connection completed for session: {}", sessionId);
266+
// explicitly close the session when the SSE connection is completed
267+
session.close();
266268
sessions.remove(sessionId);
267269
});
268270
sseBuilder.onTimeout(() -> {
269271
logger.debug("SSE connection timed out for session: {}", sessionId);
272+
session.close();
270273
sessions.remove(sessionId);
271274
});
272275
this.sessions.put(sessionId, session);

0 commit comments

Comments
 (0)