Class AbstractHttpAsyncClientBase

    • Field Detail

      • LOG

        private static final org.slf4j.Logger LOG
      • ioReactor

        private final org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor
      • executorService

        private final java.util.concurrent.ExecutorService executorService
    • Constructor Detail

      • AbstractHttpAsyncClientBase

        AbstractHttpAsyncClientBase​(org.apache.hc.core5.reactor.DefaultConnectingIOReactor ioReactor,
                                    AsyncPushConsumerRegistry pushConsumerRegistry,
                                    java.util.concurrent.ThreadFactory threadFactory)
    • Method Detail

      • register

        public void register​(java.lang.String hostname,
                             java.lang.String uriPattern,
                             org.apache.hc.core5.function.Supplier<org.apache.hc.core5.http.nio.AsyncPushConsumer> supplier)
        Specified by:
        register in class CloseableHttpAsyncClient
      • isRunning

        boolean isRunning()
      • getConnectionInitiator

        org.apache.hc.core5.reactor.ConnectionInitiator getConnectionInitiator()
      • awaitShutdown

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

        void internalClose​(org.apache.hc.core5.io.CloseMode closeMode)
      • close

        public final void close​(org.apache.hc.core5.io.CloseMode closeMode)
      • close

        public void close()