Class DefaultClientExchangeHandlerImpl<T>

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, org.apache.http.concurrent.Cancellable, org.apache.http.nio.protocol.HttpAsyncClientExchangeHandler

    class DefaultClientExchangeHandlerImpl<T>
    extends AbstractClientExchangeHandler
    Default implementation of HttpAsyncClientExchangeHandler.

    Instances of this class are expected to be accessed by one thread at a time only. The AbstractClientExchangeHandler.cancel() method can be called concurrently by multiple threads.

    • Field Detail

      • requestProducer

        private final org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer
      • responseConsumer

        private final org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T> responseConsumer
      • resultFuture

        private final org.apache.http.concurrent.BasicFuture<T> resultFuture
    • Constructor Detail

      • DefaultClientExchangeHandlerImpl

        public DefaultClientExchangeHandlerImpl​(org.apache.commons.logging.Log log,
                                                org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer,
                                                org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T> responseConsumer,
                                                org.apache.http.client.protocol.HttpClientContext localContext,
                                                org.apache.http.concurrent.BasicFuture<T> resultFuture,
                                                NHttpClientConnectionManager connmgr,
                                                org.apache.http.ConnectionReuseStrategy connReuseStrategy,
                                                org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy,
                                                InternalClientExec exec)
    • Method Detail

      • start

        public void start()
                   throws org.apache.http.HttpException,
                          java.io.IOException
        Throws:
        org.apache.http.HttpException
        java.io.IOException
      • generateRequest

        public org.apache.http.HttpRequest generateRequest()
                                                    throws java.io.IOException,
                                                           org.apache.http.HttpException
        Throws:
        java.io.IOException
        org.apache.http.HttpException
      • produceContent

        public void produceContent​(org.apache.http.nio.ContentEncoder encoder,
                                   org.apache.http.nio.IOControl ioctrl)
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • requestCompleted

        public void requestCompleted()
      • responseReceived

        public void responseReceived​(org.apache.http.HttpResponse response)
                              throws java.io.IOException,
                                     org.apache.http.HttpException
        Throws:
        java.io.IOException
        org.apache.http.HttpException
      • consumeContent

        public void consumeContent​(org.apache.http.nio.ContentDecoder decoder,
                                   org.apache.http.nio.IOControl ioctrl)
                            throws java.io.IOException
        Throws:
        java.io.IOException
      • responseCompleted

        public void responseCompleted()
                               throws java.io.IOException,
                                      org.apache.http.HttpException
        Throws:
        java.io.IOException
        org.apache.http.HttpException
      • inputTerminated

        public void inputTerminated()
      • abortConnection

        public void abortConnection()