@Contract(threading=SAFE_CONDITIONAL) public final class MinimalHttpAsyncClient extends CloseableHttpAsyncClient
CloseableHttpAsyncClient. This client is
optimized for HTTP/1.1 and HTTP/2 message transport and does not support
advanced HTTP protocol functionality such as request execution via a proxy,
state management, authentication and request redirects.
Concurrent message exchanges executed by this client will get assigned to separate connections leased from the connection pool.
| Modifier and Type | Method and Description |
|---|---|
void |
awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime) |
void |
close() |
void |
close(org.apache.hc.core5.io.CloseMode closeMode) |
protected <T> Future<T> |
doExecute(org.apache.hc.core5.http.HttpHost httpHost,
org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer,
org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer,
org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory,
org.apache.hc.core5.http.protocol.HttpContext context,
org.apache.hc.core5.concurrent.FutureCallback<T> callback) |
org.apache.hc.core5.concurrent.Cancellable |
execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler) |
org.apache.hc.core5.concurrent.Cancellable |
execute(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) |
org.apache.hc.core5.reactor.IOReactorStatus |
getStatus() |
void |
initiateShutdown() |
Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> |
lease(org.apache.hc.core5.http.HttpHost host,
org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback) |
Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> |
lease(org.apache.hc.core5.http.HttpHost host,
org.apache.hc.core5.http.protocol.HttpContext context,
org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback) |
void |
register(String hostname,
String uriPattern,
org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier) |
void |
start() |
public Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> lease(org.apache.hc.core5.http.HttpHost host, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)
public Future<org.apache.hc.core5.http.nio.AsyncClientEndpoint> lease(org.apache.hc.core5.http.HttpHost host, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.http.nio.AsyncClientEndpoint> callback)
public org.apache.hc.core5.concurrent.Cancellable execute(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)
protected <T> Future<T> doExecute(org.apache.hc.core5.http.HttpHost httpHost, org.apache.hc.core5.http.nio.AsyncRequestProducer requestProducer, org.apache.hc.core5.http.nio.AsyncResponseConsumer<T> responseConsumer, org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory, org.apache.hc.core5.http.protocol.HttpContext context, org.apache.hc.core5.concurrent.FutureCallback<T> callback)
doExecute in class CloseableHttpAsyncClientpublic final org.apache.hc.core5.concurrent.Cancellable execute(org.apache.hc.core5.http.nio.AsyncClientExchangeHandler exchangeHandler)
public final void start()
start in class CloseableHttpAsyncClientpublic void register(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
register in class CloseableHttpAsyncClientpublic final org.apache.hc.core5.reactor.IOReactorStatus getStatus()
getStatus in class CloseableHttpAsyncClientpublic final void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
throws InterruptedException
awaitShutdown in class CloseableHttpAsyncClientInterruptedExceptionpublic final void initiateShutdown()
initiateShutdown in class CloseableHttpAsyncClientpublic final void close(org.apache.hc.core5.io.CloseMode closeMode)
public void close()
Copyright © 1999–2021 The Apache Software Foundation. All rights reserved.