Class H2ConnPool
- java.lang.Object
-
- org.apache.hc.core5.reactor.AbstractIOSessionPool<HttpHost>
-
- org.apache.hc.core5.http2.nio.pool.H2ConnPool
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ModalCloseable
@Contract(threading=SAFE) public final class H2ConnPool extends AbstractIOSessionPool<HttpHost>
Pool of HTTP/2 message multiplexing capable connections.- Since:
- 5.0
-
-
Field Summary
Fields Modifier and Type Field Description private Resolver<HttpHost,java.net.InetSocketAddress>
addressResolver
private ConnectionInitiator
connectionInitiator
private TlsStrategy
tlsStrategy
private TimeValue
validateAfterInactivity
-
Constructor Summary
Constructors Constructor Description H2ConnPool(ConnectionInitiator connectionInitiator, Resolver<HttpHost,java.net.InetSocketAddress> addressResolver, TlsStrategy tlsStrategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
closeSession(IOSession ioSession, CloseMode closeMode)
protected java.util.concurrent.Future<IOSession>
connectSession(HttpHost namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
TimeValue
getValidateAfterInactivity()
void
setValidateAfterInactivity(TimeValue timeValue)
protected void
validateSession(IOSession ioSession, Callback<java.lang.Boolean> callback)
-
Methods inherited from class org.apache.hc.core5.reactor.AbstractIOSessionPool
close, close, closeIdle, enumAvailable, getRoutes, getSession, toString
-
-
-
-
Field Detail
-
connectionInitiator
private final ConnectionInitiator connectionInitiator
-
tlsStrategy
private final TlsStrategy tlsStrategy
-
validateAfterInactivity
private volatile TimeValue validateAfterInactivity
-
-
Constructor Detail
-
H2ConnPool
public H2ConnPool(ConnectionInitiator connectionInitiator, Resolver<HttpHost,java.net.InetSocketAddress> addressResolver, TlsStrategy tlsStrategy)
-
-
Method Detail
-
getValidateAfterInactivity
public TimeValue getValidateAfterInactivity()
-
setValidateAfterInactivity
public void setValidateAfterInactivity(TimeValue timeValue)
-
closeSession
protected void closeSession(IOSession ioSession, CloseMode closeMode)
- Specified by:
closeSession
in classAbstractIOSessionPool<HttpHost>
-
connectSession
protected java.util.concurrent.Future<IOSession> connectSession(HttpHost namedEndpoint, Timeout connectTimeout, FutureCallback<IOSession> callback)
- Specified by:
connectSession
in classAbstractIOSessionPool<HttpHost>
-
validateSession
protected void validateSession(IOSession ioSession, Callback<java.lang.Boolean> callback)
- Specified by:
validateSession
in classAbstractIOSessionPool<HttpHost>
-
-