Modifier and Type	Class and Description
private class	HttpAsyncRequester.InternalAsyncClientEndpoint

Modifier and Type	Field and Description
private final ManagedConnPool<HttpHost, IOSession>	connPool
private final Timeout	handshakeTimeout
private final TlsStrategy	tlsStrategy

Constructor Summary

Access Constructor and Description

Access	Constructor and Description
public	HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool, final TlsStrategy tlsStrategy, final Timeout handshakeTimeout) Use `AsyncRequesterBootstrap` to create instances of this class.
public	HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool) Use `AsyncRequesterBootstrap` to create instances of this class.

public

HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool, final TlsStrategy tlsStrategy, final Timeout handshakeTimeout)

Use AsyncRequesterBootstrap to create instances of this class.

public

Use AsyncRequesterBootstrap to create instances of this class.

Modifier and Type	Method and Description
public void	closeExpired() Implements org.apache.hc.core5.pool.ConnPoolControl.closeExpired.
public void	closeIdle(final TimeValue idleTime) Implements org.apache.hc.core5.pool.ConnPoolControl.closeIdle.
public Future<AsyncClientEndpoint>	connect(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<AsyncClientEndpoint> callback)
public Future<AsyncClientEndpoint>	connect(final HttpHost host, final Timeout timeout)
protected Future<AsyncClientEndpoint>	doConnect(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<AsyncClientEndpoint> callback)
protected void	doTlsUpgrade(final ProtocolIOSession ioSession, final NamedEndpoint endpoint, final FutureCallback<ProtocolIOSession> callback)
public void	execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext executeContext)
public void	execute(final AsyncClientExchangeHandler exchangeHandler, final Timeout timeout, final HttpContext executeContext)
public final <T> Future<T>	execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)
public final <T> Future<T>	execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)
public final <T> Future<T>	execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final FutureCallback<T> callback)
public int	getDefaultMaxPerRoute() Implements org.apache.hc.core5.pool.ConnPoolControl.getDefaultMaxPerRoute.
public int	getMaxPerRoute(final HttpHost route) Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxPerRoute.
public int	getMaxTotal() Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxTotal.
public Set<HttpHost>	getRoutes() Implements org.apache.hc.core5.pool.ConnPoolControl.getRoutes.
public PoolStats	getStats(final HttpHost route) Implements org.apache.hc.core5.pool.ConnPoolStats.getStats.
public PoolStats	getTotalStats() Implements org.apache.hc.core5.pool.ConnPoolStats.getTotalStats.
public void	setDefaultMaxPerRoute(final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setDefaultMaxPerRoute.
public void	setMaxPerRoute(final HttpHost route, final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxPerRoute.
public void	setMaxTotal(final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxTotal.

Field Detail

connPool	back to summary
private final ManagedConnPool<HttpHost, IOSession> connPool

handshakeTimeout	back to summary
private final Timeout handshakeTimeout

tlsStrategy	back to summary
private final TlsStrategy tlsStrategy

Constructor Detail

HttpAsyncRequester back to summary

HttpAsyncRequester	back to summary
public HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool, final TlsStrategy tlsStrategy, final Timeout handshakeTimeout) Use `AsyncRequesterBootstrap` to create instances of this class. Annotations @Internal Since 5.2

public HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool, final TlsStrategy tlsStrategy, final Timeout handshakeTimeout)

Use AsyncRequesterBootstrap to create instances of this class.

Annotations

@Internal

Since

5.2

HttpAsyncRequester back to summary

HttpAsyncRequester	back to summary
public HttpAsyncRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final ManagedConnPool<HttpHost, IOSession> connPool) Use `AsyncRequesterBootstrap` to create instances of this class. Annotations @Internal

Use AsyncRequesterBootstrap to create instances of this class.

Annotations

@Internal

Method Detail

closeExpired	back to summary
public void closeExpired() Implements org.apache.hc.core5.pool.ConnPoolControl.closeExpired. Annotations @Override

closeExpired

back to summary

public void closeExpired()

Implements org.apache.hc.core5.pool.ConnPoolControl.closeExpired.

Annotations

@Override

closeIdle	back to summary
public void closeIdle(final TimeValue idleTime) Implements org.apache.hc.core5.pool.ConnPoolControl.closeIdle. Annotations @Override

closeIdle

back to summary

public void closeIdle(final TimeValue idleTime)

Implements org.apache.hc.core5.pool.ConnPoolControl.closeIdle.

Annotations

@Override

connect	back to summary
public Future<AsyncClientEndpoint> connect(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<AsyncClientEndpoint> callback)

connect	back to summary
public Future<AsyncClientEndpoint> connect(final HttpHost host, final Timeout timeout)

doConnect	back to summary
protected Future<AsyncClientEndpoint> doConnect(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<AsyncClientEndpoint> callback)

doTlsUpgrade	back to summary
protected void doTlsUpgrade(final ProtocolIOSession ioSession, final NamedEndpoint endpoint, final FutureCallback<ProtocolIOSession> callback)

execute	back to summary
public void execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext executeContext)

execute	back to summary
public void execute(final AsyncClientExchangeHandler exchangeHandler, final Timeout timeout, final HttpContext executeContext)

execute	back to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)

execute	back to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)

execute	back to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final FutureCallback<T> callback)

getDefaultMaxPerRoute	back to summary
public int getDefaultMaxPerRoute() Implements org.apache.hc.core5.pool.ConnPoolControl.getDefaultMaxPerRoute. Annotations @Override

getDefaultMaxPerRoute

back to summary

public int getDefaultMaxPerRoute()

Implements org.apache.hc.core5.pool.ConnPoolControl.getDefaultMaxPerRoute.

Annotations

@Override

getMaxPerRoute	back to summary
public int getMaxPerRoute(final HttpHost route) Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxPerRoute. Annotations @Override

getMaxPerRoute

back to summary

public int getMaxPerRoute(final HttpHost route)

Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxPerRoute.

Annotations

@Override

getMaxTotal	back to summary
public int getMaxTotal() Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxTotal. Annotations @Override

getMaxTotal

back to summary

public int getMaxTotal()

Implements org.apache.hc.core5.pool.ConnPoolControl.getMaxTotal.

Annotations

@Override

getRoutes	back to summary
public Set<HttpHost> getRoutes() Implements org.apache.hc.core5.pool.ConnPoolControl.getRoutes. Annotations @Override

getRoutes

back to summary

public Set<HttpHost> getRoutes()

Implements org.apache.hc.core5.pool.ConnPoolControl.getRoutes.

Annotations

@Override

getStats	back to summary
public PoolStats getStats(final HttpHost route) Implements org.apache.hc.core5.pool.ConnPoolStats.getStats. Annotations @Override

getStats

back to summary

public PoolStats getStats(final HttpHost route)

Implements org.apache.hc.core5.pool.ConnPoolStats.getStats.

Annotations

@Override

getTotalStats	back to summary
public PoolStats getTotalStats() Implements org.apache.hc.core5.pool.ConnPoolStats.getTotalStats. Annotations @Override

getTotalStats

back to summary

public PoolStats getTotalStats()

Implements org.apache.hc.core5.pool.ConnPoolStats.getTotalStats.

Annotations

@Override

setDefaultMaxPerRoute	back to summary
public void setDefaultMaxPerRoute(final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setDefaultMaxPerRoute. Annotations @Override

setDefaultMaxPerRoute

back to summary

public void setDefaultMaxPerRoute(final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setDefaultMaxPerRoute.

Annotations

@Override

setMaxPerRoute	back to summary
public void setMaxPerRoute(final HttpHost route, final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxPerRoute. Annotations @Override

setMaxPerRoute

back to summary

public void setMaxPerRoute(final HttpHost route, final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxPerRoute.

Annotations

@Override

setMaxTotal	back to summary
public void setMaxTotal(final int max) Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxTotal. Annotations @Override

setMaxTotal

back to summary

public void setMaxTotal(final int max)

Implements org.apache.hc.core5.pool.ConnPoolControl.setMaxTotal.

Annotations

@Override

org.apache.hc.core5.http.impl.bootstrap back to summary

private Class HttpAsyncRequester.InternalAsyncClientEndpoint

Class Inheritance

extends AsyncClientEndpoint
implements TlsUpgradeCapable

java.lang.Object
org.apache.hc.core5.http.nio.AsyncClientEndpoint
org.apache.hc.core5.http.impl.bootstrap.HttpAsyncRequester.InternalAsyncClientEndpoint

All Implemented Interfaces

org.apache.hc.core5.http.nio.ssl.TlsUpgradeCapable

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicReference<PoolEntry<HttpHost, IOSession>>	poolEntryRef

Constructor Summary

Access	Constructor and Description
pack-priv	InternalAsyncClientEndpoint(final PoolEntry<HttpHost, IOSession> poolEntry)

Method Summary

Modifier and Type	Method and Description
public void	execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context) Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.execute. Initiates a message exchange using the given handler.
private IOSession	getIOSession()
public boolean	isConnected() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.isConnected. Determines if the connection to the remote endpoint is still open and valid.
public void	releaseAndDiscard() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndDiscard. Shuts down the underlying connection and removes it from the connection pool.
public void	releaseAndReuse() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndReuse. Releases the underlying connection back to the connection pool as re-usable.
public void	tlsUpgrade(final NamedEndpoint endpoint, final FutureCallback<ProtocolIOSession> callback) Implements org.apache.hc.core5.http.nio.ssl.TlsUpgradeCapable.tlsUpgrade.

Inherited from org.apache.hc.core5.http.nio.AsyncClientEndpoint:: execute execute execute execute

Field Detail

poolEntryRef	back to summary
pack-priv final AtomicReference<PoolEntry<HttpHost, IOSession>> poolEntryRef

Constructor Detail

InternalAsyncClientEndpoint	back to summary
pack-priv InternalAsyncClientEndpoint(final PoolEntry<HttpHost, IOSession> poolEntry)

Method Detail

execute back to summary

execute	back to summary
public void execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context) Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.execute. Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.execute. Initiates a message exchange using the given handler. Once the endpoint is no longer needed it MUST be released with `releaseAndReuse()` or `releaseAndDiscard()`. Annotations @Override

public void execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final HttpContext context)

Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.execute.

Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.execute.

Initiates a message exchange using the given handler.

Once the endpoint is no longer needed it MUST be released with releaseAndReuse() or releaseAndDiscard().

Annotations

@Override

getIOSession	back to summary
private IOSession getIOSession()

isConnected	back to summary
public boolean isConnected() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.isConnected. Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.isConnected. Determines if the connection to the remote endpoint is still open and valid. Annotations @Override

isConnected

back to summary

public boolean isConnected()

Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.isConnected.

Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.isConnected.

Determines if the connection to the remote endpoint is still open and valid.

Annotations

@Override

releaseAndDiscard	back to summary
public void releaseAndDiscard() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndDiscard. Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndDiscard. Shuts down the underlying connection and removes it from the connection pool. Annotations @Override

releaseAndDiscard

back to summary

public void releaseAndDiscard()

Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndDiscard.

Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndDiscard.

Shuts down the underlying connection and removes it from the connection pool.

Annotations

@Override

releaseAndReuse	back to summary
public void releaseAndReuse() Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndReuse. Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndReuse. Releases the underlying connection back to the connection pool as re-usable. Annotations @Override

releaseAndReuse

back to summary

public void releaseAndReuse()

Implements abstract org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndReuse.

Doc from org.apache.hc.core5.http.nio.AsyncClientEndpoint.releaseAndReuse.

Releases the underlying connection back to the connection pool as re-usable.

Annotations

@Override

tlsUpgrade	back to summary
public void tlsUpgrade(final NamedEndpoint endpoint, final FutureCallback<ProtocolIOSession> callback) Implements org.apache.hc.core5.http.nio.ssl.TlsUpgradeCapable.tlsUpgrade. Annotations @Override

tlsUpgrade

back to summary

public void tlsUpgrade(final NamedEndpoint endpoint, final FutureCallback<ProtocolIOSession> callback)

Implements org.apache.hc.core5.http.nio.ssl.TlsUpgradeCapable.tlsUpgrade.

Annotations

@Override

public Class HttpAsyncRequester

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class HttpAsyncRequester.InternalAsyncClientEndpoint

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail