Package org.apache.hc.core5.http2.nio.pool

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

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

connectionInitiator

private final ConnectionInitiator connectionInitiator

addressResolver

private final Resolver<HttpHost,java.net.InetSocketAddress> addressResolver

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 class AbstractIOSessionPool<HttpHost>

connectSession

protected java.util.concurrent.Future<IOSession> connectSession(HttpHost namedEndpoint,
                                                                Timeout connectTimeout,
                                                                FutureCallback<IOSession> callback)

Specified by:

connectSession in class AbstractIOSessionPool<HttpHost>

validateSession

protected void validateSession(IOSession ioSession,
                               Callback<java.lang.Boolean> callback)

Specified by:

validateSession in class AbstractIOSessionPool<HttpHost>