Class AbstractHttpAsyncClientBase
java.lang.Object
org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient
org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase
- All Implemented Interfaces:
Closeable
,AutoCloseable
,HttpAsyncClient
,org.apache.hc.core5.io.ModalCloseable
- Direct Known Subclasses:
AbstractMinimalHttpAsyncClientBase
,InternalAbstractHttpAsyncClient
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static enum
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final ExecutorService
private final org.apache.hc.core5.reactor.DefaultConnectingIOReactor
private static final org.slf4j.Logger
private final AsyncPushConsumerRegistry
private final AtomicReference
<AbstractHttpAsyncClientBase.Status> -
Constructor Summary
ConstructorsConstructorDescriptionAbstractHttpAsyncClientBase
(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory) -
Method Summary
Modifier and TypeMethodDescriptionfinal void
awaitShutdown
(org.apache.hc.core5.util.TimeValue waitTime) void
close()
final void
close
(org.apache.hc.core5.io.CloseMode closeMode) (package private) org.apache.hc.core5.reactor.ConnectionInitiator
final org.apache.hc.core5.reactor.IOReactorStatus
final void
(package private) void
internalClose
(org.apache.hc.core5.io.CloseMode closeMode) (package private) boolean
void
register
(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier) final void
start()
-
Field Details
-
LOG
private static final org.slf4j.Logger LOG -
pushConsumerRegistry
-
ioReactor
private final org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor -
executorService
-
status
-
-
Constructor Details
-
AbstractHttpAsyncClientBase
AbstractHttpAsyncClientBase(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, ThreadFactory threadFactory)
-
-
Method Details
-
start
public final void start()- Specified by:
start
in classCloseableHttpAsyncClient
-
register
public void register(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier) - Specified by:
register
in classCloseableHttpAsyncClient
-
isRunning
boolean isRunning() -
getConnectionInitiator
org.apache.hc.core5.reactor.ConnectionInitiator getConnectionInitiator() -
getStatus
public final org.apache.hc.core5.reactor.IOReactorStatus getStatus()- Specified by:
getStatus
in classCloseableHttpAsyncClient
-
awaitShutdown
public final void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime) throws InterruptedException - Specified by:
awaitShutdown
in classCloseableHttpAsyncClient
- Throws:
InterruptedException
-
initiateShutdown
public final void initiateShutdown()- Specified by:
initiateShutdown
in classCloseableHttpAsyncClient
-
internalClose
void internalClose(org.apache.hc.core5.io.CloseMode closeMode) -
close
public final void close(org.apache.hc.core5.io.CloseMode closeMode) -
close
public void close()
-