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

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, org.apache.hc.core5.reactor.ConnectionInitiator

Direct Known Subclasses:

AbstractMinimalHttpAsyncClientBase, InternalAbstractHttpAsyncClient

abstract class AbstractHttpAsyncClientBase
extends CloseableHttpAsyncClient
implements org.apache.hc.core5.reactor.ConnectionInitiator

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

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)
java.util.concurrent.Future<org.apache.hc.core5.reactor.IOSession>	connect(org.apache.hc.core5.net.NamedEndpoint remoteEndpoint, java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, org.apache.hc.core5.util.Timeout timeout, java.lang.Object attachment, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.IOSession> callback)
(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)	Deprecated. Use RequestRouter at the construction time
void	start()

Methods inherited from class org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient

doExecute, 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

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 class CloseableHttpAsyncClient

register

@Deprecated
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)

Deprecated.

Use RequestRouter at the construction time

Specified by:

register in class CloseableHttpAsyncClient

isRunning

boolean isRunning()

connect

public java.util.concurrent.Future<org.apache.hc.core5.reactor.IOSession> connect(org.apache.hc.core5.net.NamedEndpoint remoteEndpoint,
                                                                                  java.net.SocketAddress remoteAddress,
                                                                                  java.net.SocketAddress localAddress,
                                                                                  org.apache.hc.core5.util.Timeout timeout,
                                                                                  java.lang.Object attachment,
                                                                                  org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.IOSession> callback)

Specified by:

connect in interface org.apache.hc.core5.reactor.ConnectionInitiator

getConnectionInitiator

org.apache.hc.core5.reactor.ConnectionInitiator getConnectionInitiator()

getStatus

public final org.apache.hc.core5.reactor.IOReactorStatus getStatus()

Specified by:

getStatus in class CloseableHttpAsyncClient

awaitShutdown

public final void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
                         throws java.lang.InterruptedException

Specified by:

awaitShutdown in class CloseableHttpAsyncClient

Throws:

java.lang.InterruptedException

initiateShutdown

public final void initiateShutdown()

Specified by:

initiateShutdown in class CloseableHttpAsyncClient

internalClose

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

close

public final void close(org.apache.hc.core5.io.CloseMode closeMode)

Specified by:

close in interface org.apache.hc.core5.io.ModalCloseable

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable