Skip to content

Commit ab543f1

Browse files
committed
Enable multiplex message exchanges over active HTTP/2 connections
1 parent 920be79 commit ab543f1

2 files changed

Lines changed: 3 additions & 9 deletions

File tree

httpclient5/src/main/java/org/apache/hc/client5/http/impl/nio/H2SharingConnPool.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@
4141

4242
import org.apache.hc.client5.http.impl.ConnPoolSupport;
4343
import org.apache.hc.core5.annotation.Contract;
44-
import org.apache.hc.core5.annotation.Experimental;
4544
import org.apache.hc.core5.annotation.ThreadingBehavior;
4645
import org.apache.hc.core5.concurrent.CallbackContribution;
4746
import org.apache.hc.core5.concurrent.CompletedFuture;
@@ -70,7 +69,6 @@
7069
* @since 5.5
7170
*/
7271
@Contract(threading = ThreadingBehavior.SAFE)
73-
@Experimental
7472
public class H2SharingConnPool<T, C extends HttpConnection> implements ManagedConnPool<T, C> {
7573

7674
private static final Logger LOG = LoggerFactory.getLogger(H2SharingConnPool.class);

httpclient5/src/main/java/org/apache/hc/client5/http/impl/nio/PoolingAsyncClientConnectionManagerBuilder.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535
import org.apache.hc.client5.http.nio.AsyncClientConnectionOperator;
3636
import org.apache.hc.client5.http.ssl.ConscryptClientTlsStrategy;
3737
import org.apache.hc.client5.http.ssl.DefaultClientTlsStrategy;
38-
import org.apache.hc.core5.annotation.Experimental;
3938
import org.apache.hc.core5.annotation.Internal;
4039
import org.apache.hc.core5.function.Resolver;
4140
import org.apache.hc.core5.http.HttpHost;
@@ -68,7 +67,7 @@ public class PoolingAsyncClientConnectionManagerBuilder {
6867

6968
private Resolver<HttpRoute, ConnectionConfig> connectionConfigResolver;
7069
private Resolver<HttpHost, TlsConfig> tlsConfigResolver;
71-
private boolean messageMultiplexing;
70+
private boolean messageMultiplexing = true;
7271

7372
public static PoolingAsyncClientConnectionManagerBuilder create() {
7473
return new PoolingAsyncClientConnectionManagerBuilder();
@@ -249,18 +248,15 @@ public final PoolingAsyncClientConnectionManagerBuilder useSystemProperties() {
249248
}
250249

251250
/**
252-
* Use experimental connections pool implementation that acts as a caching facade
253-
* in front of a standard connection pool and shares already leased connections
251+
* Use an extra pool of connections that acts as a caching facade in front
252+
* of a standard connection pool and shares already leased connections
254253
* to multiplex message exchanges over active HTTP/2 connections.
255254
*<p>
256255
* Please note this flag has no effect on HTTP/1.1 and HTTP/1.0 connections.
257-
*<p>
258-
* This feature is considered experimenal
259256
*
260257
* @since 5.5
261258
* @return this instance.
262259
*/
263-
@Experimental
264260
public final PoolingAsyncClientConnectionManagerBuilder setMessageMultiplexing(final boolean messageMultiplexing) {
265261
this.messageMultiplexing = messageMultiplexing;
266262
return this;

0 commit comments

Comments
 (0)