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

Class InternalHttpAsyncClient

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.InternalAbstractHttpAsyncClient

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

All Implemented Interfaces:

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

@Contract(threading=SAFE_CONDITIONAL)
@Internal
public final class InternalHttpAsyncClient
extends InternalAbstractHttpAsyncClient

Internal implementation of CloseableHttpAsyncClient that can negotiate the most optimal HTTP protocol version during during the TLS handshake with ALPN extension if supported by the Java runtime.

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/interfaces inherited from class org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient

InternalAbstractHttpAsyncClient.ScheduledRequestExecution

Nested classes/interfaces inherited from class org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase

AbstractHttpAsyncClientBase.Status

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final AsyncClientConnectionManager	manager
private final HttpRoutePlanner	routePlanner
private final org.apache.hc.core5.http2.HttpVersionPolicy	versionPolicy

Constructor Summary

Constructors

Constructor

Description

InternalHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncExecChainElement execChain, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory, AsyncClientConnectionManager manager, HttpRoutePlanner routePlanner, org.apache.hc.core5.http2.HttpVersionPolicy versionPolicy, org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry, org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry, CookieStore cookieStore, CredentialsProvider credentialsProvider, RequestConfig defaultConfig, List<Closeable> closeables)

Method Summary

Modifier and Type	Method	Description
(package private) AsyncExecRuntime	createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, HttpRoute route)
(package private) HttpRoute	determineRoute(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext)

Methods inherited from class org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient

doExecute, executeImmediate, executeScheduled, internalClose

Methods inherited from class org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase

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

Methods inherited from class org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

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

Methods inherited from class java.lang.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

routePlanner

private final HttpRoutePlanner routePlanner

versionPolicy

private final org.apache.hc.core5.http2.HttpVersionPolicy versionPolicy

Constructor Details

InternalHttpAsyncClient

InternalHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor,
 AsyncExecChainElement execChain,
 AsyncPushConsumerRegistry pushConsumerRegistry,
 ThreadFactory threadFactory,
 AsyncClientConnectionManager manager,
 HttpRoutePlanner routePlanner,
 org.apache.hc.core5.http2.HttpVersionPolicy versionPolicy,
 org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry,
 org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry,
 CookieStore cookieStore,
 CredentialsProvider credentialsProvider,
 RequestConfig defaultConfig,
 List<Closeable> closeables)

Method Details

createAsyncExecRuntime

AsyncExecRuntime createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory,
 HttpRoute route)

Specified by:

createAsyncExecRuntime in class InternalAbstractHttpAsyncClient

determineRoute

HttpRoute determineRoute(org.apache.hc.core5.http.HttpHost httpHost,
 HttpClientContext clientContext)
                  throws org.apache.hc.core5.http.HttpException

Specified by:

determineRoute in class InternalAbstractHttpAsyncClient

Throws:

org.apache.hc.core5.http.HttpException