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
FieldsModifier and TypeFieldDescription(package private) final AtomicReference
<PoolEntry<HttpHost, IOSession>> -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
execute
(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, HttpContext context) Initiates a message exchange using the given handler.private IOSession
boolean
Determines if the connection to the remote endpoint is still open and valid.void
Shuts down the underlying connection and removes it from the connection pool.void
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
-
Field Details
-
poolEntryRef
-
-
Constructor Details
-
InternalAsyncClientEndpoint
-
-
Method Details
-
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()
orAsyncClientEndpoint.releaseAndDiscard()
.- Specified by:
execute
in classAsyncClientEndpoint
-
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 classAsyncClientEndpoint
-
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 classAsyncClientEndpoint
-
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 classAsyncClientEndpoint
-
tlsUpgrade
- Specified by:
tlsUpgrade
in interfaceTlsUpgradeCapable
-