Skip to content

Commit 53f5740

Browse files
committed
fix java 17 related issue
Signed-off-by: Christian Tzolov <christian.tzolov@broadcom.com>
1 parent 8c39fb8 commit 53f5740

File tree

1 file changed

+6
-8
lines changed

1 file changed

+6
-8
lines changed

mcp/src/main/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransport.java

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -426,7 +426,12 @@ public Mono<Void> sendMessage(JSONRPCMessage message) {
426426
try {
427427
return this.serializeMessage(message)
428428
.flatMap(body -> sendHttpPost(messageEndpointUri, body))
429-
.doOnNext(this::logIfNotOk)
429+
.doOnNext(response -> {
430+
if (response.statusCode() != 200 && response.statusCode() != 201 && response.statusCode() != 202
431+
&& response.statusCode() != 206) {
432+
logger.error("Error sending message: {}", response.statusCode());
433+
}
434+
})
430435
.doOnError(error -> {
431436
if (!isClosing) {
432437
logger.error("Error sending message: {}", error.getMessage());
@@ -465,13 +470,6 @@ private Mono<HttpResponse<Void>> sendHttpPost(final String endpoint, final Strin
465470
return Mono.fromFuture(httpClient.sendAsync(request, HttpResponse.BodyHandlers.discarding()));
466471
}
467472

468-
private void logIfNotOk(final HttpResponse<?> response) {
469-
if (response.statusCode() != 200 && response.statusCode() != 201 && response.statusCode() != 202
470-
&& response.statusCode() != 206) {
471-
logger.error("Error sending message: {}", response.statusCode());
472-
}
473-
}
474-
475473
/**
476474
* Gracefully closes the transport connection.
477475
*

0 commit comments

Comments
 (0)