Package org.apache.hc.core5.http.impl.bootstrap

Class HttpAsyncRequester

java.lang.Object

org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase

org.apache.hc.core5.http.impl.bootstrap.AsyncRequester

org.apache.hc.core5.http.impl.bootstrap.HttpAsyncRequester

All Implemented Interfaces:

Closeable, AutoCloseable, ModalCloseable, ConnPoolControl<HttpHost>, ConnPoolStats<HttpHost>, ConnectionInitiator, IOReactor, IOReactorService

Direct Known Subclasses:

H2AsyncRequester

public class HttpAsyncRequester
extends AsyncRequester
implements ConnPoolControl<HttpHost>

HTTP/1.1 client side message exchange initiator.

Since:

5.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	HttpAsyncRequester.InternalAsyncClientEndpoint

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class org.apache.hc.core5.http.impl.bootstrap.AsyncRequester

awaitShutdown, close, close, getIOReactor, getStatus, initiateShutdown, requestSession, start

Methods inherited from class org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase

connect

Methods inherited from class java.lang.Object

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

Field Details

connPool

private final ManagedConnPool<HttpHost,IOSession> connPool

tlsStrategy

private final TlsStrategy tlsStrategy

handshakeTimeout

private final Timeout handshakeTimeout

Constructor Details

HttpAsyncRequester

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

Use AsyncRequesterBootstrap to create instances of this class.

Since:

5.2

HttpAsyncRequester

@Internal
public HttpAsyncRequester(IOReactorConfig ioReactorConfig,
 IOEventHandlerFactory eventHandlerFactory,
 Decorator<IOSession> ioSessionDecorator,
 Callback<Exception> exceptionCallback,
 IOSessionListener sessionListener,
 ManagedConnPool<HttpHost,IOSession> connPool)

Use AsyncRequesterBootstrap to create instances of this class.

Method Details

getTotalStats

public PoolStats getTotalStats()

Specified by:

getTotalStats in interface ConnPoolStats<HttpHost>

getStats

public PoolStats getStats(HttpHost route)

Specified by:

getStats in interface ConnPoolStats<HttpHost>

setMaxTotal

public void setMaxTotal(int max)

Specified by:

setMaxTotal in interface ConnPoolControl<HttpHost>

getMaxTotal

public int getMaxTotal()

Specified by:

getMaxTotal in interface ConnPoolControl<HttpHost>

setDefaultMaxPerRoute

public void setDefaultMaxPerRoute(int max)

Specified by:

setDefaultMaxPerRoute in interface ConnPoolControl<HttpHost>

getDefaultMaxPerRoute

public int getDefaultMaxPerRoute()

Specified by:

getDefaultMaxPerRoute in interface ConnPoolControl<HttpHost>

setMaxPerRoute

public void setMaxPerRoute(HttpHost route,
 int max)

Specified by:

setMaxPerRoute in interface ConnPoolControl<HttpHost>

getMaxPerRoute

public int getMaxPerRoute(HttpHost route)

Specified by:

getMaxPerRoute in interface ConnPoolControl<HttpHost>

closeIdle

public void closeIdle(TimeValue idleTime)

Specified by:

closeIdle in interface ConnPoolControl<HttpHost>

closeExpired

public void closeExpired()

Specified by:

closeExpired in interface ConnPoolControl<HttpHost>

getRoutes

public Set<HttpHost> getRoutes()

Specified by:

getRoutes in interface ConnPoolControl<HttpHost>

connect

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

doConnect

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

connect

public Future<AsyncClientEndpoint> connect(HttpHost host,
 Timeout timeout)

execute

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

execute

public void execute(AsyncClientExchangeHandler exchangeHandler,
 Timeout timeout,
 HttpContext executeContext)

execute

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

execute

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

execute

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

doTlsUpgrade

protected void doTlsUpgrade(ProtocolIOSession ioSession,
 NamedEndpoint endpoint,
 FutureCallback<ProtocolIOSession> callback)