Interface AsyncClientConnectionManager
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
,org.apache.hc.core5.io.ModalCloseable
- All Known Implementing Classes:
PoolingAsyncClientConnectionManager
@Contract(threading=SAFE) public interface AsyncClientConnectionManager extends org.apache.hc.core5.io.ModalCloseable
Represents a manager of persistent non-blocking client connections.The purpose of an HTTP connection manager is to serve as a factory for new HTTP connections, manage persistent connections and synchronize access to persistent connections making sure that only one thread of execution can have access to a connection at a time.
Implementations of this interface must be thread-safe. Access to shared data must be synchronized as methods of this interface may be executed from multiple threads.
- Since:
- 5.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description java.util.concurrent.Future<AsyncConnectionEndpoint>
connect(AsyncConnectionEndpoint endpoint, org.apache.hc.core5.reactor.ConnectionInitiator connectionInitiator, org.apache.hc.core5.util.Timeout connectTimeout, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Connects the endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).java.util.concurrent.Future<AsyncConnectionEndpoint>
lease(java.lang.String id, HttpRoute route, java.lang.Object state, org.apache.hc.core5.util.Timeout requestTimeout, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Returns aFuture
object which can be used to obtain anAsyncConnectionEndpoint
or to cancel the request by callingFuture.cancel(boolean)
.void
release(AsyncConnectionEndpoint endpoint, java.lang.Object newState, org.apache.hc.core5.util.TimeValue validDuration)
Releases the endpoint back to the manager making it potentially re-usable by other consumers.void
upgrade(AsyncConnectionEndpoint endpoint, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context)
Upgrades transport security of the given endpoint by using the TLS security protocol.default void
upgrade(AsyncConnectionEndpoint endpoint, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Upgrades transport security of the given endpoint by using the TLS security protocol.
-
-
-
Method Detail
-
lease
java.util.concurrent.Future<AsyncConnectionEndpoint> lease(java.lang.String id, HttpRoute route, java.lang.Object state, org.apache.hc.core5.util.Timeout requestTimeout, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Returns aFuture
object which can be used to obtain anAsyncConnectionEndpoint
or to cancel the request by callingFuture.cancel(boolean)
.Please note that newly allocated endpoints can be leased
disconnected
. The consumer of the endpoint is responsible for fully establishing the route to the endpoint target by callingconnect(AsyncConnectionEndpoint, ConnectionInitiator, Timeout, Object, HttpContext, FutureCallback)
in order to connect directly to the target or to the first proxy hop, and optionally callingupgrade(AsyncConnectionEndpoint, Object, HttpContext)
method to upgrade the underlying transport to Transport Layer Security after having executed aCONNECT
method to all intermediate proxy hops.- Parameters:
id
- unique operation ID ornull
.route
- HTTP route of the requested connection.state
- expected state of the connection ornull
if the connection is not expected to carry any state.requestTimeout
- lease request timeout.callback
- result callback.
-
release
void release(AsyncConnectionEndpoint endpoint, java.lang.Object newState, org.apache.hc.core5.util.TimeValue validDuration)
Releases the endpoint back to the manager making it potentially re-usable by other consumers. Optionally, the maximum period of how long the manager should keep the connection alive can be defined usingvalidDuration
andtimeUnit
parameters.- Parameters:
endpoint
- the managed endpoint.newState
- the new connection state ofnull
if state-less.validDuration
- the duration of time this connection is valid for reuse.
-
connect
java.util.concurrent.Future<AsyncConnectionEndpoint> connect(AsyncConnectionEndpoint endpoint, org.apache.hc.core5.reactor.ConnectionInitiator connectionInitiator, org.apache.hc.core5.util.Timeout connectTimeout, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Connects the endpoint to the initial hop (connection target in case of a direct route or to the first proxy hop in case of a route via a proxy or multiple proxies).- Parameters:
endpoint
- the managed endpoint.connectTimeout
- connect timeout.context
- the actual HTTP context.attachment
- connect request attachment.callback
- result callback.
-
upgrade
void upgrade(AsyncConnectionEndpoint endpoint, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context)
Upgrades transport security of the given endpoint by using the TLS security protocol.- Parameters:
endpoint
- the managed endpoint.attachment
- the attachment the upgrade attachment object.context
- the actual HTTP context.
-
upgrade
default void upgrade(AsyncConnectionEndpoint endpoint, java.lang.Object attachment, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<AsyncConnectionEndpoint> callback)
Upgrades transport security of the given endpoint by using the TLS security protocol.- Parameters:
endpoint
- the managed endpoint.attachment
- the attachment the upgrade attachment object.context
- the actual HTTP context.callback
- result callback.- Since:
- 5.2
-
-