Class InternalHttpAsyncClient

java.lang.Object
org.apache.hc.client5.http.impl.async.CloseableHttpAsyncClient
org.apache.hc.client5.http.impl.async.InternalHttpAsyncClient
All Implemented Interfaces:
Closeable, AutoCloseable, HttpAsyncClient, org.apache.hc.core5.io.ModalCloseable, org.apache.hc.core5.reactor.ConnectionInitiator
@Contract(threading=SAFE_CONDITIONAL) @Internal public final class InternalHttpAsyncClient extends CloseableHttpAsyncClient
Internal implementation of CloseableHttpAsyncClient that can negotiate the most optimal HTTP protocol version during during the TLS handshake with ALPN extension if supported by the Java runtime.

Concurrent message exchanges executed by this client will get assigned to separate connections leased from the connection pool.

Since:
5.0

  • Method Summary

    Modifier and Type
    Method
    Description
    final void
    awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime)
     
    void
    close()
     
    final void
    close(org.apache.hc.core5.io.CloseMode closeMode)
     
    Future<org.apache.hc.core5.reactor.IOSession>
    connect(org.apache.hc.core5.net.NamedEndpoint remoteEndpoint, SocketAddress remoteAddress, SocketAddress localAddress, org.apache.hc.core5.util.Timeout timeout, Object attachment, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.IOSession> callback)
     
    protected <T> Future<T>
    doExecute(org.apache.hc.core5.http.HttpHost target, 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)
     
    final org.apache.hc.core5.reactor.IOReactorStatus
    getStatus()
     
    final void
    initiateShutdown()
     
    void
    register(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
    Deprecated.
    Use RequestRouter at the construction time
    final void
    start()
     

    Methods inherited from class CloseableHttpAsyncClient

    execute, execute, execute, execute, execute, execute, register

    Methods inherited from class Object

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

  • Method Details

    • doExecute

      protected <T> Future<T> doExecute(org.apache.hc.core5.http.HttpHost target, 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)
      Specified by:
      doExecute in class CloseableHttpAsyncClient

    • start

      public final void start()
      Specified by:
      start in class CloseableHttpAsyncClient

    • register

      @Deprecated public void register(String hostname, String uriPattern, org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
      Deprecated.
      Use RequestRouter at the construction time
      Specified by:
      register in class CloseableHttpAsyncClient

    • connect

      public Future<org.apache.hc.core5.reactor.IOSession> connect(org.apache.hc.core5.net.NamedEndpoint remoteEndpoint, SocketAddress remoteAddress, SocketAddress localAddress, org.apache.hc.core5.util.Timeout timeout, Object attachment, org.apache.hc.core5.concurrent.FutureCallback<org.apache.hc.core5.reactor.IOSession> callback)
      Specified by:
      connect in interface org.apache.hc.core5.reactor.ConnectionInitiator

    • getStatus

      public final org.apache.hc.core5.reactor.IOReactorStatus getStatus()
      Specified by:
      getStatus in class CloseableHttpAsyncClient

    • awaitShutdown

      public final void awaitShutdown(org.apache.hc.core5.util.TimeValue waitTime) throws InterruptedException
      Specified by:
      awaitShutdown in class CloseableHttpAsyncClient
      Throws:
      InterruptedException

    • initiateShutdown

      public final void initiateShutdown()
      Specified by:
      initiateShutdown in class CloseableHttpAsyncClient

    • close

      public final void close(org.apache.hc.core5.io.CloseMode closeMode)
      Specified by:
      close in interface org.apache.hc.core5.io.ModalCloseable

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable