Class PoolingAsyncClientConnectionManager.InternalConnectionEndpoint

java.lang.Object

org.apache.hc.client5.http.nio.AsyncConnectionEndpoint

org.apache.hc.client5.http.impl.nio.PoolingAsyncClientConnectionManager.InternalConnectionEndpoint

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hc.core5.io.ModalCloseable, org.apache.hc.core5.util.Identifiable

Enclosing class:

PoolingAsyncClientConnectionManager

static class PoolingAsyncClientConnectionManager.InternalConnectionEndpoint
extends AsyncConnectionEndpoint
implements org.apache.hc.core5.util.Identifiable

Since:

5.0

Field Summary

Fields

Modifier and Type	Field	Description
private final String	id
private final AtomicReference<org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection>>	poolEntryRef

Constructor Summary

Constructors

Constructor	Description
InternalConnectionEndpoint(org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection> poolEntry)

Method Summary

Modifier and Type	Method	Description
void	close(org.apache.hc.core5.io.CloseMode closeMode)
(package private) org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection>	detach()
void	execute(String exchangeId, org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context)	Initiates a message exchange using the given handler.
String	getId()
(package private) org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection>	getPoolEntry()
(package private) org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection>	getValidatedPoolEntry()
boolean	isConnected()	Determines if the connection to the remote endpoint is still open and valid.
void	setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)	Sets socket timeout.

Methods inherited from class AsyncConnectionEndpoint

close, execute, execute, execute, execute, execute

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

poolEntryRef

private final AtomicReference<org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection>> poolEntryRef

id

private final String id

Constructor Details

InternalConnectionEndpoint

InternalConnectionEndpoint(org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection> poolEntry)

Method Details

getId

public String getId()

Specified by:

getId in interface org.apache.hc.core5.util.Identifiable

getPoolEntry

org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection> getPoolEntry()

getValidatedPoolEntry

org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection> getValidatedPoolEntry()

detach

org.apache.hc.core5.pool.PoolEntry<HttpRoute, ManagedAsyncClientConnection> detach()

close

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

Specified by:

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

isConnected

public boolean isConnected()

Description copied from class: AsyncConnectionEndpoint

Determines if the connection to the remote endpoint is still open and valid.

Specified by:

isConnected in class AsyncConnectionEndpoint

setSocketTimeout

public void setSocketTimeout(org.apache.hc.core5.util.Timeout timeout)

Description copied from class: AsyncConnectionEndpoint

Sets socket timeout.

Specified by:

setSocketTimeout in class AsyncConnectionEndpoint

Parameters:

timeout - the socket timeout.

execute

public void execute(String exchangeId,
 org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler,
 org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory,
 org.apache.hc.core5.http.protocol.HttpContext context)

Description copied from class: AsyncConnectionEndpoint

Initiates a message exchange using the given handler.

Specified by:

execute in class AsyncConnectionEndpoint

Parameters:

exchangeId - unique operation ID or null.

exchangeHandler - the message exchange handler.

pushHandlerFactory - the push handler factory.

context - the execution context.