Top Inners Fields Constructors Methods
org.apache.hc.client5.http.impl.async

pack-priv abstract Class AbstractHttpAsyncClientBase

extends CloseableHttpAsyncClient
Class Inheritance
Known Direct Subclasses
org.apache.hc.client5.http.impl.async.AbstractMinimalHttpAsyncClientBase, org.apache.hc.client5.http.impl.async.InternalAbstractHttpAsyncClient
Imports
java.util.concurrent.ExecutorService, .Executors, .ThreadFactory, java.util.concurrent.atomic.AtomicReference, org.apache.hc.core5.function.Supplier, org.apache.hc.core5.http.nio.AsyncPushConsumer, org.apache.hc.core5.io.CloseMode, org.apache.hc.core5.reactor.ConnectionInitiator, .DefaultConnectingIOReactor, .IOReactorStatus, org.apache.hc.core5.util.TimeValue, org.slf4j.Logger, .LoggerFactory

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static enum
AbstractHttpAsyncClientBase.Status

Field Summary

Modifier and TypeField and Description
private final ExecutorService
executorService

private final DefaultConnectingIOReactor
ioReactor

private static final Logger
LOG

private final AsyncPushConsumerRegistry
pushConsumerRegistry

private final AtomicReference<AbstractHttpAsyncClientBase.Status>
status

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractHttpAsyncClientBase(final DefaultConnectingIOReactor ioReactor, final AsyncPushConsumerRegistry pushConsumerRegistry, final ThreadFactory threadFactory)

Method Summary

Modifier and TypeMethod and Description
public final void
awaitShutdown(final TimeValue waitTime)

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.awaitShutdown.

public final void
close(final CloseMode
How to close the receiver.
closeMode)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it.
public void
close()

Implements java.io.Closeable.close.

Closes this stream and releases any system resources associated with it.
pack-priv ConnectionInitiator
getConnectionInitiator()

public final IOReactorStatus
getStatus()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.getStatus.

public final void
initiateShutdown()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.initiateShutdown.

pack-priv void
internalClose(final CloseMode closeMode)

pack-priv boolean
isRunning()

public void
register(final String hostname, final String uriPattern, final Supplier<AsyncPushConsumer> supplier)

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.register.

public final void
start()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.start.

Inherited from org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient:
doExecuteexecuteexecuteexecuteexecuteexecuteexecuteregister

Field Detail

executorServiceback to summary
private final ExecutorService executorService
ioReactorback to summary
private final DefaultConnectingIOReactor ioReactor
LOGback to summary
private static final Logger LOG
pushConsumerRegistryback to summary
private final AsyncPushConsumerRegistry pushConsumerRegistry
statusback to summary
private final AtomicReference<AbstractHttpAsyncClientBase.Status> status

Constructor Detail

AbstractHttpAsyncClientBaseback to summary
pack-priv AbstractHttpAsyncClientBase(final DefaultConnectingIOReactor ioReactor, final AsyncPushConsumerRegistry pushConsumerRegistry, final ThreadFactory threadFactory)

Method Detail

awaitShutdownback to summary
public final void awaitShutdown(final TimeValue waitTime) throws InterruptedException

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.awaitShutdown.

Annotations
@Override
closeback to summary
public final void close(final CloseMode closeMode)

Implements org.apache.hc.core5.io.ModalCloseable.close.

Doc from org.apache.hc.core5.io.ModalCloseable.close.

Closes this process or endpoint and releases any system resources associated with it. If the endpoint or the process is already closed then invoking this method has no effect.

Parameters
closeMode:CloseMode

How to close the receiver.

Annotations
@Override
closeback to summary
public void close()

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations
@Override
getConnectionInitiatorback to summary
pack-priv ConnectionInitiator getConnectionInitiator()
getStatusback to summary
public final IOReactorStatus getStatus()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.getStatus.

Annotations
@Override
initiateShutdownback to summary
public final void initiateShutdown()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.initiateShutdown.

Annotations
@Override
internalCloseback to summary
pack-priv void internalClose(final CloseMode closeMode)
isRunningback to summary
pack-priv boolean isRunning()
registerback to summary
public void register(final String hostname, final String uriPattern, final Supplier<AsyncPushConsumer> supplier)

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.register.

Annotations
@Override
startback to summary
public final void start()

Implements abstract org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient.start.

Annotations
@Override
org.apache.hc.client5.http.impl.async back to summary

pack-priv final Enum AbstractHttpAsyncClientBase.Status

extends Enum<AbstractHttpAsyncClientBase.Status>
Class Inheritance

Field Summary

Modifier and TypeField and Description
public static final AbstractHttpAsyncClientBase.Status
READY

public static final AbstractHttpAsyncClientBase.Status
RUNNING

public static final AbstractHttpAsyncClientBase.Status
TERMINATED

Constructor Summary

AccessConstructor and Description
private
Status()

Method Summary

Modifier and TypeMethod and Description
public static AbstractHttpAsyncClientBase.Status
valueOf(String name)

public static AbstractHttpAsyncClientBase.Status[]
values()

Inherited from java.lang.Enum:
clonecompareTodescribeConstableequalsfinalizegetDeclaringClasshashCodenameordinaltoStringvalueOf

Field Detail

READYback to summary
public static final AbstractHttpAsyncClientBase.Status READY
RUNNINGback to summary
public static final AbstractHttpAsyncClientBase.Status RUNNING
TERMINATEDback to summary
public static final AbstractHttpAsyncClientBase.Status TERMINATED

Constructor Detail

Statusback to summary
private Status()

Method Detail

valueOfback to summary
public static AbstractHttpAsyncClientBase.Status valueOf(String name)
valuesback to summary
public static AbstractHttpAsyncClientBase.Status[] values()