diff --git a/documentation/jetty/modules/code/examples/src/main/java/org/eclipse/jetty/docs/programming/client/http/HTTPClientDocs.java b/documentation/jetty/modules/code/examples/src/main/java/org/eclipse/jetty/docs/programming/client/http/HTTPClientDocs.java index a85e80ad2210..adaeb47a05ea 100644 --- a/documentation/jetty/modules/code/examples/src/main/java/org/eclipse/jetty/docs/programming/client/http/HTTPClientDocs.java +++ b/documentation/jetty/modules/code/examples/src/main/java/org/eclipse/jetty/docs/programming/client/http/HTTPClientDocs.java @@ -1070,7 +1070,7 @@ public void setConnectionPool() throws Exception // the transport supports multiplexing requests on the same connection. int maxRequestsPerConnection = 1; - HttpClientTransport transport = httpClient.getTransport(); + HttpClientTransport transport = httpClient.getHttpClientTransport(); // Set the ConnectionPool.Factory using a lambda. transport.setConnectionPoolFactory(destination -> @@ -1087,7 +1087,7 @@ public void preCreateConnections() throws Exception httpClient.start(); // For HTTP/1.1, you need to explicitly configure to initialize connections. - if (httpClient.getTransport() instanceof HttpClientTransportOverHTTP http1) + if (httpClient.getHttpClientTransport() instanceof HttpClientTransportOverHTTP http1) http1.setInitializeConnections(true); // Create a dummy request to the server you want to pre-create connections to. diff --git a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java index 0c7701676e88..1d5426e7f588 100644 --- a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java +++ b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java @@ -157,7 +157,19 @@ public HttpClient(HttpClientTransport transport) installBean(decoderFactories); } + /** + * @deprecated use {@link #getHttpClientTransport()} instead + */ + @Deprecated(forRemoval = true, since = "12.1.0") public HttpClientTransport getTransport() + { + return getHttpClientTransport(); + } + + /** + * @return the {@link HttpClientTransport} associated with this {@code HttpClient} + */ + public HttpClientTransport getHttpClientTransport() { return transport; } @@ -451,7 +463,7 @@ private HttpRequest newHttpRequest(HttpConversation conversation, URI uri) public Destination resolveDestination(Request request) { - HttpClientTransport transport = getTransport(); + HttpClientTransport transport = getHttpClientTransport(); Origin origin = transport.newOrigin(request); Destination destination = resolveDestination(origin); if (LOG.isDebugEnabled()) @@ -488,7 +500,7 @@ public Destination resolveDestination(Origin origin) { if (v == null || v.stale()) { - HttpDestination newDestination = (HttpDestination)getTransport().newDestination(k); + HttpDestination newDestination = (HttpDestination)getHttpClientTransport().newDestination(k); // Start the destination before it's published to other threads. addManaged(newDestination); if (destinationSweeper != null) diff --git a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpDestination.java b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpDestination.java index 564b86128d0c..e7a86ae620ab 100644 --- a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpDestination.java +++ b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpDestination.java @@ -92,7 +92,7 @@ public HttpDestination(HttpClient client, Origin origin) host += ":" + port; hostField = new HttpField(HttpHeader.HOST, host); - ClientConnectionFactory connectionFactory = client.getTransport(); + ClientConnectionFactory connectionFactory = client.getHttpClientTransport(); boolean intrinsicallySecure = origin.getTransport().isIntrinsicallySecure(); ProxyConfiguration proxyConfig = client.getProxyConfiguration(); @@ -186,7 +186,7 @@ protected void doStop() throws Exception protected ConnectionPool newConnectionPool(HttpClient client) { - return client.getTransport().getConnectionPoolFactory().newConnectionPool(this); + return client.getHttpClientTransport().getConnectionPoolFactory().newConnectionPool(this); } protected Queue newExchangeQueue(HttpClient client) diff --git a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/HttpReceiverOverHTTP.java b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/HttpReceiverOverHTTP.java index f74dbc6c149f..da1f86f047e8 100644 --- a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/HttpReceiverOverHTTP.java +++ b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/HttpReceiverOverHTTP.java @@ -61,7 +61,7 @@ public HttpReceiverOverHTTP(HttpChannelOverHTTP channel) super(channel); HttpClient httpClient = channel.getHttpDestination().getHttpClient(); parser = new HttpParser(this, httpClient.getMaxResponseHeadersSize(), httpClient.getHttpCompliance()); - HttpClientTransport transport = httpClient.getTransport(); + HttpClientTransport transport = httpClient.getHttpClientTransport(); if (transport instanceof HttpClientTransportOverHTTP httpTransport) { parser.setHeaderCacheSize(httpTransport.getHeaderCacheSize()); diff --git a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/ProtocolHttpUpgrader.java b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/ProtocolHttpUpgrader.java index 95a9cfead224..220f649bc036 100644 --- a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/ProtocolHttpUpgrader.java +++ b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/internal/ProtocolHttpUpgrader.java @@ -65,7 +65,7 @@ public void upgrade(Response response, EndPoint endPoint, Callback callback) if (response.getHeaders().contains(HttpHeader.UPGRADE, protocol)) { HttpClient httpClient = destination.getHttpClient(); - HttpClientTransport transport = httpClient.getTransport(); + HttpClientTransport transport = httpClient.getHttpClientTransport(); if (transport instanceof HttpClientTransportDynamic) { HttpClientTransportDynamic dynamicTransport = (HttpClientTransportDynamic)transport; diff --git a/jetty-core/jetty-fcgi/jetty-fcgi-client/src/main/java/org/eclipse/jetty/fcgi/client/transport/internal/HttpSenderOverFCGI.java b/jetty-core/jetty-fcgi/jetty-fcgi-client/src/main/java/org/eclipse/jetty/fcgi/client/transport/internal/HttpSenderOverFCGI.java index eb88bd279e33..17c2e18a8a29 100644 --- a/jetty-core/jetty-fcgi/jetty-fcgi-client/src/main/java/org/eclipse/jetty/fcgi/client/transport/internal/HttpSenderOverFCGI.java +++ b/jetty-core/jetty-fcgi/jetty-fcgi-client/src/main/java/org/eclipse/jetty/fcgi/client/transport/internal/HttpSenderOverFCGI.java @@ -95,7 +95,7 @@ protected void sendHeaders(HttpExchange exchange, ByteBuffer contentBuffer, bool } // Give a chance to the transport implementation to customize the FastCGI headers - HttpClientTransportOverFCGI transport = (HttpClientTransportOverFCGI)getHttpChannel().getHttpDestination().getHttpClient().getTransport(); + HttpClientTransportOverFCGI transport = (HttpClientTransportOverFCGI)getHttpChannel().getHttpDestination().getHttpClient().getHttpClientTransport(); transport.customize(request, fcgiHeaders); ByteBufferPool.Accumulator accumulator = new ByteBufferPool.Accumulator(); diff --git a/jetty-core/jetty-http2/jetty-http2-tests/src/test/java/org/eclipse/jetty/http2/tests/MaxConcurrentStreamsTest.java b/jetty-core/jetty-http2/jetty-http2-tests/src/test/java/org/eclipse/jetty/http2/tests/MaxConcurrentStreamsTest.java index 6986d205184b..72013c58fb7a 100644 --- a/jetty-core/jetty-http2/jetty-http2-tests/src/test/java/org/eclipse/jetty/http2/tests/MaxConcurrentStreamsTest.java +++ b/jetty-core/jetty-http2/jetty-http2-tests/src/test/java/org/eclipse/jetty/http2/tests/MaxConcurrentStreamsTest.java @@ -380,7 +380,7 @@ public boolean handle(Request request, org.eclipse.jetty.server.Response respons httpClient.setMaxConnectionsPerDestination(32768); httpClient.setMaxRequestsQueuedPerDestination(1024 * 1024); - httpClient.getTransport().setConnectionPoolFactory(destination -> + httpClient.getHttpClientTransport().setConnectionPoolFactory(destination -> { try { diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/ConnectionPoolTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/ConnectionPoolTest.java index 7903366de4b0..004408857e5d 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/ConnectionPoolTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/ConnectionPoolTest.java @@ -48,7 +48,7 @@ public void testPreCreateConnections(Transport transport) throws Exception startClient(transport); client.setMaxConnectionsPerDestination(maxConnectionsPerDestination); if (transport == Transport.HTTPS) - ((HttpClientTransportOverHTTP)client.getTransport()).setInitializeConnections(true); + ((HttpClientTransportOverHTTP)client.getHttpClientTransport()).setInitializeConnections(true); var request = client.newRequest(newURI(transport)); Destination destination = client.resolveDestination(request); diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP1TransportTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP1TransportTest.java index a403cf1eb145..06b8c3cca624 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP1TransportTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP1TransportTest.java @@ -81,7 +81,7 @@ public void testDefaultTransport() throws Exception Destination destination = destinations.get(0); assertThat(destination.getOrigin().getTransport(), sameInstance(Transport.TCP_IP)); - HttpClientTransportOverHTTP httpClientTransport = (HttpClientTransportOverHTTP)httpClient.getTransport(); + HttpClientTransportOverHTTP httpClientTransport = (HttpClientTransportOverHTTP)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(1)); } @@ -117,7 +117,7 @@ public void testMemoryTransport() throws Exception assertThat(response.getStatus(), is(HttpStatus.OK_200)); - HttpClientTransportOverHTTP httpClientTransport = (HttpClientTransportOverHTTP)httpClient.getTransport(); + HttpClientTransportOverHTTP httpClientTransport = (HttpClientTransportOverHTTP)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(0)); } diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP2TransportTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP2TransportTest.java index b44963701dd7..4611f39a331a 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP2TransportTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP2TransportTest.java @@ -96,7 +96,7 @@ public void testDefaultTransport() throws Exception Destination destination = destinations.get(0); assertThat(destination.getOrigin().getTransport(), sameInstance(Transport.TCP_IP)); - HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getTransport(); + HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getHTTP2Client().getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(1)); } @@ -132,7 +132,7 @@ public void testMemoryTransport() throws Exception assertThat(response.getStatus(), is(HttpStatus.OK_200)); - HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getTransport(); + HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getHTTP2Client().getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(0)); } @@ -201,7 +201,7 @@ public void testQUICTransportWithH2(WorkDir workDir) throws Exception SslContextFactory.Client sslClient = new SslContextFactory.Client(true); httpClient.setSslContextFactory(sslClient); - HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getTransport(); + HttpClientTransportOverHTTP2 httpClientTransport = (HttpClientTransportOverHTTP2)httpClient.getHttpClientTransport(); // ALPN is negotiated by QUIC. httpClientTransport.setUseALPN(false); ClientQuicConfiguration clientQuicConfig = new ClientQuicConfiguration(sslClient, null); diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP3TransportTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP3TransportTest.java index 8d020b0aeae0..c18b472b50ed 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP3TransportTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HTTP3TransportTest.java @@ -108,7 +108,7 @@ public void testDefaultTransport() throws Exception transport = wrapper.unwrap(); assertThat(transport, sameInstance(Transport.UDP_IP)); - HttpClientTransportOverHTTP3 httpClientTransport = (HttpClientTransportOverHTTP3)httpClient.getTransport(); + HttpClientTransportOverHTTP3 httpClientTransport = (HttpClientTransportOverHTTP3)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getHTTP3Client().getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(1)); } @@ -148,7 +148,7 @@ public void testMemoryTransport() throws Exception assertThat(response.getStatus(), is(HttpStatus.OK_200)); - HttpClientTransportOverHTTP3 httpClientTransport = (HttpClientTransportOverHTTP3)httpClient.getTransport(); + HttpClientTransportOverHTTP3 httpClientTransport = (HttpClientTransportOverHTTP3)httpClient.getHttpClientTransport(); int networkConnections = httpClientTransport.getHTTP3Client().getClientConnector().getSelectorManager().getTotalKeys(); assertThat(networkConnections, is(0)); } diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java index 43bb16e32b22..a8c283595a9e 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java @@ -1253,7 +1253,7 @@ public boolean handle(Request request, org.eclipse.jetty.server.Response respons // - the connection can be used by two concurrent requests; // - the connection is pre-created. client.setMaxConnectionsPerDestination(1); - client.getTransport().setConnectionPoolFactory(destination -> + client.getHttpClientTransport().setConnectionPoolFactory(destination -> { MultiplexConnectionPool pool = new MultiplexConnectionPool(destination, 1, 2); LifeCycle.start(pool); diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/RoundRobinConnectionPoolTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/RoundRobinConnectionPoolTest.java index bb6ff64bd448..dc9428cbd715 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/RoundRobinConnectionPoolTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/RoundRobinConnectionPoolTest.java @@ -66,7 +66,7 @@ public boolean handle(Request request, Response response, Callback callback) int maxConnections = 3; CompletableFuture setup = new CompletableFuture<>(); - client.getTransport().setConnectionPoolFactory(destination -> + client.getHttpClientTransport().setConnectionPoolFactory(destination -> { RoundRobinConnectionPool pool = new RoundRobinConnectionPool(destination, maxConnections); LifeCycle.start(pool); @@ -146,7 +146,7 @@ public boolean handle(Request request, Response response, Callback callback) }); CompletableFuture setup = new CompletableFuture<>(); - client.getTransport().setConnectionPoolFactory(destination -> + client.getHttpClientTransport().setConnectionPoolFactory(destination -> { RoundRobinConnectionPool pool = new RoundRobinConnectionPool(destination, maxConnections); LifeCycle.start(pool); @@ -226,7 +226,7 @@ public boolean handle(Request request, Response response, Callback callback) }); if (transport == Transport.H3) ((QuicServerConnector)connector).getQuicConfiguration().setMaxBidirectionalRemoteStreams(maxUsage); - client.getTransport().setConnectionPoolFactory(destination -> + client.getHttpClientTransport().setConnectionPoolFactory(destination -> { RoundRobinConnectionPool pool = new RoundRobinConnectionPool(destination, maxConnections, maxMultiplex); pool.setMaxUsage(maxUsage); diff --git a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/TLSHandshakeFailureTest.java b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/TLSHandshakeFailureTest.java index f8af4a461f36..877705e6b5a2 100644 --- a/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/TLSHandshakeFailureTest.java +++ b/jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/TLSHandshakeFailureTest.java @@ -87,7 +87,7 @@ private void testTLSWrapFailure(Transport transport, TLSHandshakeAction action, { start(transport, new EmptyServerHandler()); client.stop(); - client = new HttpClient(client.getTransport()) + client = new HttpClient(client.getHttpClientTransport()) { @Override public ClientConnectionFactory newSslClientConnectionFactory(SslContextFactory.Client sslContextFactory, ClientConnectionFactory connectionFactory) @@ -163,7 +163,7 @@ private void testTLSUnwrapFailure(Transport transport, TLSHandshakeAction action { start(transport, new EmptyServerHandler()); client.stop(); - client = new HttpClient(client.getTransport()) + client = new HttpClient(client.getHttpClientTransport()) { @Override public ClientConnectionFactory newSslClientConnectionFactory(SslContextFactory.Client sslContextFactory, ClientConnectionFactory connectionFactory) diff --git a/jetty-ee10/jetty-ee10-tests/jetty-ee10-test-client-transports/src/test/java/org/eclipse/jetty/ee10/test/client/transport/ServerTimeoutsTest.java b/jetty-ee10/jetty-ee10-tests/jetty-ee10-test-client-transports/src/test/java/org/eclipse/jetty/ee10/test/client/transport/ServerTimeoutsTest.java index fbe33e198685..1f24f1cbcfd9 100644 --- a/jetty-ee10/jetty-ee10-tests/jetty-ee10-test-client-transports/src/test/java/org/eclipse/jetty/ee10/test/client/transport/ServerTimeoutsTest.java +++ b/jetty-ee10/jetty-ee10-tests/jetty-ee10-test-client-transports/src/test/java/org/eclipse/jetty/ee10/test/client/transport/ServerTimeoutsTest.java @@ -609,7 +609,7 @@ protected void service(HttpServletRequest request, HttpServletResponse response) } } }); - ((HttpClientTransportOverHTTP2)client.getTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); + ((HttpClientTransportOverHTTP2)client.getHttpClientTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); // Setup the client to read slower than the min data rate. BlockingQueue objects = new LinkedBlockingQueue<>(); diff --git a/jetty-ee11/jetty-ee11-tests/jetty-ee11-test-client-transports/src/test/java/org/eclipse/jetty/ee11/test/client/transport/ServerTimeoutsTest.java b/jetty-ee11/jetty-ee11-tests/jetty-ee11-test-client-transports/src/test/java/org/eclipse/jetty/ee11/test/client/transport/ServerTimeoutsTest.java index 7d33175d9516..d35fb1a5c12a 100644 --- a/jetty-ee11/jetty-ee11-tests/jetty-ee11-test-client-transports/src/test/java/org/eclipse/jetty/ee11/test/client/transport/ServerTimeoutsTest.java +++ b/jetty-ee11/jetty-ee11-tests/jetty-ee11-test-client-transports/src/test/java/org/eclipse/jetty/ee11/test/client/transport/ServerTimeoutsTest.java @@ -609,7 +609,7 @@ protected void service(HttpServletRequest request, HttpServletResponse response) } } }); - ((HttpClientTransportOverHTTP2)client.getTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); + ((HttpClientTransportOverHTTP2)client.getHttpClientTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); // Setup the client to read slower than the min data rate. BlockingQueue objects = new LinkedBlockingQueue<>(); diff --git a/jetty-ee9/jetty-ee9-tests/jetty-ee9-test-client-transports/src/test/java/org/eclipse/jetty/ee9/test/client/transport/ServerTimeoutsTest.java b/jetty-ee9/jetty-ee9-tests/jetty-ee9-test-client-transports/src/test/java/org/eclipse/jetty/ee9/test/client/transport/ServerTimeoutsTest.java index cf73e7a0c108..f532600ea406 100644 --- a/jetty-ee9/jetty-ee9-tests/jetty-ee9-test-client-transports/src/test/java/org/eclipse/jetty/ee9/test/client/transport/ServerTimeoutsTest.java +++ b/jetty-ee9/jetty-ee9-tests/jetty-ee9-test-client-transports/src/test/java/org/eclipse/jetty/ee9/test/client/transport/ServerTimeoutsTest.java @@ -592,7 +592,7 @@ protected void service(HttpServletRequest request, HttpServletResponse response) } } }); - ((HttpClientTransportOverHTTP2)client.getTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); + ((HttpClientTransportOverHTTP2)client.getHttpClientTransport()).getHTTP2Client().setInitialStreamRecvWindow(FlowControlStrategy.DEFAULT_WINDOW_SIZE); // Setup the client to read slower than the min data rate. BlockingQueue objects = new LinkedBlockingQueue<>();