feat: Add error logging for HttpClientSseClientTransport

jkma · jkma · commit 945c26d9e2bd · 2025-07-01T19:24:03.000+08:00
diff --git a/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java b/mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java
@@ -421,10 +421,10 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {
 				.build();
 
 			return Mono.fromFuture(
-					httpClient.sendAsync(request, HttpResponse.BodyHandlers.discarding()).thenAccept(response -> {
+					httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()).thenAccept(response -> {
 						if (response.statusCode() != 200 && response.statusCode() != 201 && response.statusCode() != 202
 								&& response.statusCode() != 206) {
-							logger.error("Error sending message: {}", response.statusCode());
+							logger.error("Error sending message, code: {}, body: {}", response.statusCode(), response.body());
 						}
 					}));
 		}

Original file line number	Diff line number	Diff line change
`@@ -421,10 +421,10 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {`
`421`	`421`	`.build();`
`422`	`422`
`423`	`423`	`return Mono.fromFuture(`
`424`		`- httpClient.sendAsync(request, HttpResponse.BodyHandlers.discarding()).thenAccept(response -> {`
	`424`	`+ httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()).thenAccept(response -> {`
`425`	`425`	`if (response.statusCode() != 200 && response.statusCode() != 201 && response.statusCode() != 202`
`426`	`426`	`&& response.statusCode() != 206) {`
`427`		`- logger.error("Error sending message: {}", response.statusCode());`
	`427`	`+ logger.error("Error sending message, code: {}, body: {}", response.statusCode(), response.body());`
`428`	`428`	`}`
`429`	`429`	`}));`
`430`	`430`	`}`