fix: When call the MCP SSE endpoint, the Content-Type header not passed by default (#489)
This commit is contained in:
parent
4b7d72928b
commit
1e29adefb0
1 changed files with 2 additions and 2 deletions
|
|
@ -244,8 +244,7 @@ public class HttpClientSseClientTransport implements McpClientTransport {
|
||||||
|
|
||||||
private ObjectMapper objectMapper = new ObjectMapper();
|
private ObjectMapper objectMapper = new ObjectMapper();
|
||||||
|
|
||||||
private HttpRequest.Builder requestBuilder = HttpRequest.newBuilder()
|
private HttpRequest.Builder requestBuilder = HttpRequest.newBuilder();
|
||||||
.header("Content-Type", "application/json");
|
|
||||||
|
|
||||||
private AsyncHttpRequestCustomizer httpRequestCustomizer = AsyncHttpRequestCustomizer.NOOP;
|
private AsyncHttpRequestCustomizer httpRequestCustomizer = AsyncHttpRequestCustomizer.NOOP;
|
||||||
|
|
||||||
|
|
@ -540,6 +539,7 @@ public class HttpClientSseClientTransport implements McpClientTransport {
|
||||||
return Mono.defer(() -> {
|
return Mono.defer(() -> {
|
||||||
var builder = this.requestBuilder.copy()
|
var builder = this.requestBuilder.copy()
|
||||||
.uri(requestUri)
|
.uri(requestUri)
|
||||||
|
.header("Content-Type", "application/json")
|
||||||
.header(MCP_PROTOCOL_VERSION_HEADER_NAME, MCP_PROTOCOL_VERSION)
|
.header(MCP_PROTOCOL_VERSION_HEADER_NAME, MCP_PROTOCOL_VERSION)
|
||||||
.POST(HttpRequest.BodyPublishers.ofString(body));
|
.POST(HttpRequest.BodyPublishers.ofString(body));
|
||||||
return Mono.from(this.httpRequestCustomizer.customize(builder, "POST", requestUri, body));
|
return Mono.from(this.httpRequestCustomizer.customize(builder, "POST", requestUri, body));
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue