Skip to content

Commit d5b00c9

Browse files
committed
Merge branch 'main' into issue115/httpClientSseClientTransport_internal
2 parents 3bb5c28 + 63724f1 commit d5b00c9

File tree

18 files changed

+731
-613
lines changed

18 files changed

+731
-613
lines changed

mcp-spring/mcp-spring-webflux/src/main/java/io/modelcontextprotocol/server/transport/WebFluxSseServerTransportProvider.java

+5
Original file line numberDiff line numberDiff line change
@@ -306,6 +306,11 @@ private Mono<ServerResponse> handleMessage(ServerRequest request) {
306306

307307
McpServerSession session = sessions.get(request.queryParam("sessionId").get());
308308

309+
if (session == null) {
310+
return ServerResponse.status(HttpStatus.NOT_FOUND)
311+
.bodyValue(new McpError("Session not found: " + request.queryParam("sessionId").get()));
312+
}
313+
309314
return request.bodyToMono(String.class).flatMap(body -> {
310315
try {
311316
McpSchema.JSONRPCMessage message = McpSchema.deserializeJsonRpcMessage(objectMapper, body);

0 commit comments

Comments
 (0)