Class AbstractHttpAsyncClientBase
- java.lang.Object
-
- org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient
-
- org.apache.hc.client5.http.impl.async.AbstractHttpAsyncClientBase
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,HttpAsyncClient
,org.apache.hc.core5.io.ModalCloseable
- Direct Known Subclasses:
AbstractMinimalHttpAsyncClientBase
,InternalAbstractHttpAsyncClient
abstract class AbstractHttpAsyncClientBase extends CloseableHttpAsyncClient
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
AbstractHttpAsyncClientBase.Status
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.ExecutorService
executorService
private org.apache.hc.core5.reactor.DefaultConnectingIOReactor
ioReactor
private static org.slf4j.Logger
LOG
private AsyncPushConsumerRegistry
pushConsumerRegistry
private java.util.concurrent.atomic.AtomicReference<AbstractHttpAsyncClientBase.Status>
status
-
Constructor Summary
Constructors Constructor Description AbstractHttpAsyncClientBase(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, java.util.concurrent.ThreadFactory threadFactory)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
void
close()
void
close(org.apache.hc.core5.io.CloseMode closeMode)
(package private) org.apache.hc.core5.reactor.ConnectionInitiator
getConnectionInitiator()
org.apache.hc.core5.reactor.IOReactorStatus
getStatus()
void
initiateShutdown()
(package private) void
internalClose(org.apache.hc.core5.io.CloseMode closeMode)
(package private) boolean
isRunning()
void
register(java.lang.String hostname, java.lang.String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
void
start()
-
-
-
Field Detail
-
LOG
private static final org.slf4j.Logger LOG
-
pushConsumerRegistry
private final AsyncPushConsumerRegistry pushConsumerRegistry
-
ioReactor
private final org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor
-
executorService
private final java.util.concurrent.ExecutorService executorService
-
status
private final java.util.concurrent.atomic.AtomicReference<AbstractHttpAsyncClientBase.Status> status
-
-
Constructor Detail
-
AbstractHttpAsyncClientBase
AbstractHttpAsyncClientBase(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor, AsyncPushConsumerRegistry pushConsumerRegistry, java.util.concurrent.ThreadFactory threadFactory)
-
-
Method Detail
-
start
public final void start()
- Specified by:
start
in classCloseableHttpAsyncClient
-
register
public void register(java.lang.String hostname, java.lang.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 java.lang.InterruptedException
- Specified by:
awaitShutdown
in classCloseableHttpAsyncClient
- Throws:
java.lang.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()
-
-