Package org.apache.hc.core5.http.impl.bootstrap

Class HttpAsyncRequester.InternalAsyncClientEndpoint

java.lang.Object

org.apache.hc.core5.http.nio.AsyncClientEndpoint

org.apache.hc.core5.http.impl.bootstrap.HttpAsyncRequester.InternalAsyncClientEndpoint

All Implemented Interfaces:

TlsUpgradeCapable

Enclosing class:

HttpAsyncRequester

private class HttpAsyncRequester.InternalAsyncClientEndpoint
extends AsyncClientEndpoint
implements TlsUpgradeCapable

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicReference<PoolEntry<HttpHost,IOSession>>	poolEntryRef

Constructor Summary

Constructors

Constructor	Description
InternalAsyncClientEndpoint(PoolEntry<HttpHost,IOSession> poolEntry)

Method Summary

Modifier and Type	Method	Description
void	execute(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context)	Initiates a message exchange using the given handler.
private IOSession	getIOSession()
boolean	isConnected()	Determines if the connection to the remote endpoint is still open and valid.
void	releaseAndDiscard()	Shuts down the underlying connection and removes it from the connection pool.
void	releaseAndReuse()	Releases the underlying connection back to the connection pool as re-usable.
void	tlsUpgrade(NamedEndpoint endpoint, FutureCallback<ProtocolIOSession> callback)

Methods inherited from class org.apache.hc.core5.http.nio.AsyncClientEndpoint

execute, execute, execute, execute

Methods inherited from class java.lang.Object

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

Field Details

poolEntryRef

final AtomicReference<PoolEntry<HttpHost,IOSession>> poolEntryRef

Constructor Details

InternalAsyncClientEndpoint

InternalAsyncClientEndpoint(PoolEntry<HttpHost,IOSession> poolEntry)

Method Details

getIOSession

private IOSession getIOSession()

execute

public void execute(AsyncClientExchangeHandler exchangeHandler,
 HandlerFactory<AsyncPushConsumer> pushHandlerFactory,
 HttpContext context)

Description copied from class: AsyncClientEndpoint

Initiates a message exchange using the given handler.

Once the endpoint is no longer needed it MUST be released with AsyncClientEndpoint.releaseAndReuse() or AsyncClientEndpoint.releaseAndDiscard().

Specified by:

execute in class AsyncClientEndpoint

isConnected

public boolean isConnected()

Description copied from class: AsyncClientEndpoint

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

Specified by:

isConnected in class AsyncClientEndpoint

releaseAndReuse

public void releaseAndReuse()

Description copied from class: AsyncClientEndpoint

Releases the underlying connection back to the connection pool as re-usable.

Specified by:

releaseAndReuse in class AsyncClientEndpoint

releaseAndDiscard

public void releaseAndDiscard()

Description copied from class: AsyncClientEndpoint

Shuts down the underlying connection and removes it from the connection pool.

Specified by:

releaseAndDiscard in class AsyncClientEndpoint

tlsUpgrade

public void tlsUpgrade(NamedEndpoint endpoint,
 FutureCallback<ProtocolIOSession> callback)

Specified by:

tlsUpgrade in interface TlsUpgradeCapable