Class MinimalHttpAsyncClient

java.lang.Object

org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase

org.apache.hc.client5.http.impl.async.AbstractMinimalHttpAsyncClientBase

org.apache.hc.client5.http.impl.async.MinimalHttpAsyncClient

All Implemented Interfaces:

Closeable, AutoCloseable, HttpAsyncClient, org.apache.hc.core5.io.ModalCloseable

@Contract(threading=SAFE_CONDITIONAL)
public final class MinimalHttpAsyncClient
extends AbstractMinimalHttpAsyncClientBase

Minimal implementation of CloseableHttpAsyncClient. This client is optimized for HTTP/1.1 and HTTP/2 message transport and does not support advanced HTTP protocol functionality such as request execution via a proxy, state management, authentication and request redirects.

Concurrent message exchanges executed by this client will get assigned to separate connections leased from the connection pool.

Since:

5.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	MinimalHttpAsyncClient.InternalAsyncClientEndpoint

Nested classes/interfaces inherited from class AbstractHttpAsyncClientBase

AbstractHttpAsyncClientBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final AsyncClientConnectionManager	manager
private final SchemePortResolver	schemePortResolver
private final TlsConfig	tlsConfig

Constructor Summary

Constructors

Constructor	Description
MinimalHttpAsyncClient(org.apache.hc.core5.reactor.IOEventHandlerFactory eventHandlerFactory, AsyncPushConsumerRegistry pushConsumerRegistry, org.apache.hc.core5.reactor.IOReactorConfig reactorConfig, ThreadFactory threadFactory, ThreadFactory workerThreadFactory, AsyncClientConnectionManager manager, SchemePortResolver schemePortResolver, TlsConfig tlsConfig)

Method Summary

Modifier and Type	Method	Description
org.apache.hc.core5.concurrent.Cancellable	execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context)
Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint>	lease(org.apache.hc.core5.http.HttpHost host, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)
Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint>	lease(org.apache.hc.core5.http.HttpHost host, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)
private Future<AsyncConnectionEndpoint>	leaseEndpoint(org.apache.hc.core5.http.HttpHost host, org.apache.hc.core5.util.Timeout connectionRequestTimeout, org.apache.hc.core5.util.Timeout connectTimeout, HttpClientContext clientContext, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)

Methods inherited from class AbstractMinimalHttpAsyncClientBase

doExecute, execute

Methods inherited from class AbstractHttpAsyncClientBase

awaitShutdown, close, close, getConnectionInitiator, getStatus, initiateShutdown, internalClose, isRunning, register, start

Methods inherited from class CloseableHttpAsyncClient

execute, execute, execute, execute, execute, execute, register

Methods inherited from class Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

manager

private final AsyncClientConnectionManager manager

schemePortResolver

private final SchemePortResolver schemePortResolver

tlsConfig

private final TlsConfig tlsConfig

Constructor Details

MinimalHttpAsyncClient

MinimalHttpAsyncClient(org.apache.hc.core5.reactor.IOEventHandlerFactory eventHandlerFactory,
 AsyncPushConsumerRegistry pushConsumerRegistry,
 org.apache.hc.core5.reactor.IOReactorConfig reactorConfig,
 ThreadFactory threadFactory,
 ThreadFactory workerThreadFactory,
 AsyncClientConnectionManager manager,
 SchemePortResolver schemePortResolver,
 TlsConfig tlsConfig)

Method Details

leaseEndpoint

private Future<AsyncConnectionEndpoint> leaseEndpoint(org.apache.hc.core5.http.HttpHost host,
 org.apache.hc.core5.util.Timeout connectionRequestTimeout,
 org.apache.hc.core5.util.Timeout connectTimeout,
 HttpClientContext clientContext,
 org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)

lease

public Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> lease(org.apache.hc.core5.http.HttpHost host,
 org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)

lease

public Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> lease(org.apache.hc.core5.http.HttpHost host,
 org.apache.hc.core5.http.protocol.HttpContext context,
 org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)

execute

public org.apache.hc.core5.concurrent.Cancellable execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler,
 org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory,
 org.apache.hc.core5.http.protocol.HttpContext context)

Specified by:

execute in class AbstractMinimalHttpAsyncClientBase