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

Class InternalAbstractHttpAsyncClient

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

All Implemented Interfaces:

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

Direct Known Subclasses:

InternalH2AsyncClient, InternalHttpAsyncClient

abstract class InternalAbstractHttpAsyncClient
extends AbstractHttpAsyncClientBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	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 final org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory>	authSchemeRegistry
private final ConcurrentLinkedQueue<Closeable>	closeables
private final org.apache.hc.core5.http.config.Lookup<CookieSpecFactory>	cookieSpecRegistry
private final CookieStore	cookieStore
private final CredentialsProvider	credentialsProvider
private final RequestConfig	defaultConfig
private final AsyncExecChainElement	execChain
private static final org.slf4j.Logger	LOG
private final ScheduledExecutorService	scheduledExecutorService
private final AsyncExecChain.Scheduler	scheduler
private static final ThreadFactory	SCHEDULER_THREAD_FACTORY

Constructor Summary

Constructors

Constructor

Description

InternalAbstractHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory, AsyncExecChainElement execChain, 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) abstract AsyncExecRuntime	createAsyncExecRuntime(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)
(package private) abstract HttpRoute	determineRoute(org.apache.hc.core5.http.HttpHost httpHost, HttpClientContext clientContext)
protected <T> Future<T>	doExecute(org.apache.hc.core5.http.HttpHost httpHost, org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<T> callback)
(package private) void	executeImmediate(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback)
(package private) void	executeScheduled(org.apache.hc.core5.http.HttpRequest request, org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer, AsyncExecChain.Scope scope, AsyncExecChain chain, AsyncExecCallback asyncExecCallback, org.apache.hc.core5.util.TimeValue delay)
(package private) void	internalClose(org.apache.hc.core5.io.CloseMode closeMode)
private void	setupContext(HttpClientContext context)

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

SCHEDULER_THREAD_FACTORY

private static final ThreadFactory SCHEDULER_THREAD_FACTORY

LOG

private static final org.slf4j.Logger LOG

execChain

private final AsyncExecChainElement execChain

cookieSpecRegistry

private final org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry

authSchemeRegistry

private final org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry

cookieStore

private final CookieStore cookieStore

credentialsProvider

private final CredentialsProvider credentialsProvider

defaultConfig

private final RequestConfig defaultConfig

closeables

private final ConcurrentLinkedQueue<Closeable> closeables

scheduledExecutorService

private final ScheduledExecutorService scheduledExecutorService

scheduler

private final AsyncExecChain.Scheduler scheduler

Constructor Details

InternalAbstractHttpAsyncClient

InternalAbstractHttpAsyncClient(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor,
 AsyncPushConsumerRegistry pushConsumerRegistry,
 ThreadFactory threadFactory,
 AsyncExecChainElement execChain,
 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

internalClose

void internalClose(org.apache.hc.core5.io.CloseMode closeMode)

Overrides:

internalClose in class AbstractHttpAsyncClientBase

setupContext

private void setupContext(HttpClientContext context)

createAsyncExecRuntime

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

determineRoute

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

Throws:

org.apache.hc.core5.http.HttpException

doExecute

protected <T> Future<T> doExecute(org.apache.hc.core5.http.HttpHost httpHost,
 org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer,
 org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer,
 org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory,
 org.apache.hc.core5.http.protocol.HttpContext context,
 org.apache.hc.core5.concurrent.FutureCallback<T> callback)

Specified by:

doExecute in class CloseableHttpAsyncClient

executeImmediate

void executeImmediate(org.apache.hc.core5.http.HttpRequest request,
 org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer,
 AsyncExecChain.Scope scope,
 AsyncExecChain chain,
 AsyncExecCallback asyncExecCallback)
               throws org.apache.hc.core5.http.HttpException,
IOException

Throws:

org.apache.hc.core5.http.HttpException

IOException

executeScheduled

void executeScheduled(org.apache.hc.core5.http.HttpRequest request,
 org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer,
 AsyncExecChain.Scope scope,
 AsyncExecChain chain,
 AsyncExecCallback asyncExecCallback,
 org.apache.hc.core5.util.TimeValue delay)