test: configure HTTP client with HTTP/1.1 and Content-Type header

tzolov · tzolov · commit 5313dd1786ff · 2025-07-09T12:23:38.000+02:00
- Set HttpClient to use HTTP/1.1 version explicitly
- Add Content-Type: application/json header to HttpRequest builder
- Update TestHttpClientSseClientTransport constructor in test class
diff --git a/mcp/src/test/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransportTests.java b/mcp/src/test/java/io/modelcontextprotocol/client/transport/HttpClientSseClientTransportTests.java
@@ -59,7 +59,9 @@ static class TestHttpClientSseClientTransport extends HttpClientSseClientTranspo
 		private Sinks.Many<ServerSentEvent<String>> events = Sinks.many().unicast().onBackpressureBuffer();
 
 		public TestHttpClientSseClientTransport(final String baseUri) {
-			super(HttpClient.newHttpClient(), HttpRequest.newBuilder(), baseUri, "/sse", new ObjectMapper());
+			super(HttpClient.newBuilder().version(HttpClient.Version.HTTP_1_1).build(),
+					HttpRequest.newBuilder().header("Content-Type", "application/json"), baseUri, "/sse",
+					new ObjectMapper());
 		}
 
 		public int getInboundMessageCount() {

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,9 @@ static class TestHttpClientSseClientTransport extends HttpClientSseClientTranspo`
`59`	`59`	`private Sinks.Many<ServerSentEvent<String>> events = Sinks.many().unicast().onBackpressureBuffer();`
`60`	`60`
`61`	`61`	`public TestHttpClientSseClientTransport(final String baseUri) {`
`62`		`- super(HttpClient.newHttpClient(), HttpRequest.newBuilder(), baseUri, "/sse", new ObjectMapper());`
	`62`	`+ super(HttpClient.newBuilder().version(HttpClient.Version.HTTP_1_1).build(),`
	`63`	`+ HttpRequest.newBuilder().header("Content-Type", "application/json"), baseUri, "/sse",`
	`64`	`+ new ObjectMapper());`
`63`	`65`	`}`
`64`	`66`
`65`	`67`	`public int getInboundMessageCount() {`