Class InternalAbstractHttpAsyncClient

    • Field Detail

      • SCHEDULER_THREAD_FACTORY

        private static final java.util.concurrent.ThreadFactory SCHEDULER_THREAD_FACTORY
      • LOG

        private static final org.slf4j.Logger LOG
      • cookieSpecRegistry

        private final org.apache.hc.core5.http.config.Lookup<CookieSpecFactory> cookieSpecRegistry
      • authSchemeRegistry

        private final org.apache.hc.core5.http.config.Lookup<AuthSchemeFactory> authSchemeRegistry
      • closeables

        private final java.util.concurrent.ConcurrentLinkedQueue<java.io.Closeable> closeables
      • scheduledExecutorService

        private final java.util.concurrent.ScheduledExecutorService scheduledExecutorService
    • Method Detail

      • createAsyncExecRuntime

        abstract AsyncExecRuntime createAsyncExecRuntime​(org.apache.hc.core5.http.nio.HandlerFactory<org.apache.hc.core5.http.nio.AsyncPushConsumer> pushHandlerFactory)
      • determineRoute

        abstract HttpRoute determineRoute​(org.apache.hc.core5.http.HttpHost httpHost,
                                          HttpClientContext clientContext)
                                   throws org.apache.hc.core5.http.HttpException
        Throws:
        org.apache.hc.core5.http.HttpException
      • doExecute

        protected <T> java.util.concurrent.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)
        Specified by:
        doExecute in class CloseableHttpAsyncClient
      • executeImmediate

        void executeImmediate​(org.apache.hc.core5.http.HttpRequest request,
                              org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer,
                              AsyncExecChain.Scope scope,
                              AsyncExecChain chain,
                              AsyncExecCallback asyncExecCallback)
                       throws org.apache.hc.core5.http.HttpException,
                              java.io.IOException
        Throws:
        org.apache.hc.core5.http.HttpException
        java.io.IOException
      • executeScheduled

        void executeScheduled​(org.apache.hc.core5.http.HttpRequest request,
                              org.apache.hc.core5.http.nio.AsyncEntityProducer entityProducer,
                              AsyncExecChain.Scope scope,
                              AsyncExecChain chain,
                              AsyncExecCallback asyncExecCallback,
                              org.apache.hc.core5.util.TimeValue delay)