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:

java.io.Closeable, java.lang.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 org.slf4j.Logger	LOG
private AsyncClientConnectionManager	manager
private HttpRoutePlanner	routePlanner
private TlsConfig	tlsConfig

Constructor Summary

Constructors

Constructor

Description

InternalHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncExecChainElement execChain, AsyncPushConsumerRegistry pushConsumerRegistry, java.util.concurrent.ThreadFactory threadFactory, AsyncClientConnectionManager manager, HttpRoutePlanner routePlanner, TlsConfig tlsConfig, org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry, org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry, CookieStore cookieStore, CredentialsProvider credentialsProvider, RequestConfig defaultConfig, java.util.List<java.io.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)
(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 Detail

LOG

private static final org.slf4j.Logger LOG

manager

private final AsyncClientConnectionManager manager

routePlanner

private final HttpRoutePlanner routePlanner

tlsConfig

private final TlsConfig tlsConfig

Constructor Detail

InternalHttpAsyncClient

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

Method Detail

createAsyncExecRuntime

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

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