Class PipeliningClientExchangeHandlerImpl<T>

java.lang.Object

org.apache.http.impl.nio.client.AbstractClientExchangeHandler

org.apache.http.impl.nio.client.PipeliningClientExchangeHandlerImpl<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.http.concurrent.Cancellable, org.apache.http.nio.protocol.HttpAsyncClientExchangeHandler

@Pipelined
class PipeliningClientExchangeHandlerImpl<T>
extends AbstractClientExchangeHandler

HttpAsyncClientExchangeHandler implementation that supports HTTP message pipelining.

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 Summary

Fields

Modifier and Type	Field	Description
private final org.apache.http.protocol.HttpProcessor	httpProcessor
private final org.apache.http.client.protocol.HttpClientContext	localContext
private final Queue<org.apache.http.nio.protocol.HttpAsyncRequestProducer>	requestProducerQueue
private final AtomicReference<org.apache.http.nio.protocol.HttpAsyncRequestProducer>	requestProducerRef
private final Queue<org.apache.http.HttpRequest>	requestQueue
private final Queue<org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>>	responseConsumerQueue
private final AtomicReference<org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>>	responseConsumerRef
private final org.apache.http.concurrent.BasicFuture<List<T>>	resultFuture
private final Queue<T>	resultQueue
private final org.apache.http.HttpHost	target

Fields inherited from class AbstractClientExchangeHandler

log

Constructor Summary

Constructors

Constructor

Description

PipeliningClientExchangeHandlerImpl(org.apache.commons.logging.Log log, org.apache.http.HttpHost target, List<? extends org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducers, List<? extends org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumers, org.apache.http.client.protocol.HttpClientContext localContext, org.apache.http.concurrent.BasicFuture<List<T>> resultFuture, NHttpClientConnectionManager connmgr, org.apache.http.protocol.HttpProcessor httpProcessor, org.apache.http.ConnectionReuseStrategy connReuseStrategy, org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy)

Method Summary

Modifier and Type	Method	Description
void	abortConnection()
private void	closeConsumer(org.apache.http.nio.protocol.HttpAsyncResponseConsumer<?> responseConsumer)
private void	closeProducer(org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer)
void	consumeContent(org.apache.http.nio.ContentDecoder decoder, org.apache.http.nio.IOControl ioctrl)
(package private) boolean	executionCancelled()
(package private) void	executionFailed(Exception ex)
org.apache.http.HttpRequest	generateRequest()
void	inputTerminated()
void	produceContent(org.apache.http.nio.ContentEncoder encoder, org.apache.http.nio.IOControl ioctrl)
(package private) void	releaseResources()
void	requestCompleted()
void	responseCompleted()
void	responseReceived(org.apache.http.HttpResponse response)
void	start()

Methods inherited from class AbstractClientExchangeHandler

cancel, close, discardConnection, failed, getActualRoute, getConnection, getCurrentRequest, getCurrentResponse, getId, getRoute, isCompleted, isDone, isRouteEstablished, manageConnectionPersistence, markCompleted, markConnectionNonReusable, onRouteComplete, onRouteToProxy, onRouteToTarget, onRouteTunnelToTarget, onRouteUpgrade, releaseConnection, requestConnection, setCurrentRequest, setCurrentResponse, setRoute, verifytRoute

Methods inherited from class Object

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

Field Details

target

private final org.apache.http.HttpHost target

requestProducerQueue

private final Queue<org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducerQueue

responseConsumerQueue

private final Queue<org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumerQueue

requestQueue

private final Queue<org.apache.http.HttpRequest> requestQueue

resultQueue

private final Queue<T> resultQueue

localContext

private final org.apache.http.client.protocol.HttpClientContext localContext

resultFuture

private final org.apache.http.concurrent.BasicFuture<List<T>> resultFuture

httpProcessor

private final org.apache.http.protocol.HttpProcessor httpProcessor

requestProducerRef

private final AtomicReference<org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducerRef

responseConsumerRef

private final AtomicReference<org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumerRef

Constructor Details

PipeliningClientExchangeHandlerImpl

public PipeliningClientExchangeHandlerImpl(org.apache.commons.logging.Log log,
 org.apache.http.HttpHost target,
 List<? extends org.apache.http.nio.protocol.HttpAsyncRequestProducer> requestProducers,
 List<? extends org.apache.http.nio.protocol.HttpAsyncResponseConsumer<T>> responseConsumers,
 org.apache.http.client.protocol.HttpClientContext localContext,
 org.apache.http.concurrent.BasicFuture<List<T>> resultFuture,
 NHttpClientConnectionManager connmgr,
 org.apache.http.protocol.HttpProcessor httpProcessor,
 org.apache.http.ConnectionReuseStrategy connReuseStrategy,
 org.apache.http.conn.ConnectionKeepAliveStrategy keepaliveStrategy)

Method Details

closeProducer

private void closeProducer(org.apache.http.nio.protocol.HttpAsyncRequestProducer requestProducer)

closeConsumer

private void closeConsumer(org.apache.http.nio.protocol.HttpAsyncResponseConsumer<?> responseConsumer)

releaseResources

void releaseResources()

Specified by:

releaseResources in class AbstractClientExchangeHandler

executionFailed

void executionFailed(Exception ex)

Specified by:

executionFailed in class AbstractClientExchangeHandler

executionCancelled

boolean executionCancelled()

Specified by:

executionCancelled in class AbstractClientExchangeHandler

start

public void start()
           throws org.apache.http.HttpException,
IOException

Throws:

org.apache.http.HttpException

IOException

generateRequest

public org.apache.http.HttpRequest generateRequest()
                                            throws IOException,
org.apache.http.HttpException

Throws:

IOException

org.apache.http.HttpException

produceContent

public void produceContent(org.apache.http.nio.ContentEncoder encoder,
 org.apache.http.nio.IOControl ioctrl)
                    throws IOException

Throws:

IOException

requestCompleted

public void requestCompleted()

responseReceived

public void responseReceived(org.apache.http.HttpResponse response)
                      throws IOException,
org.apache.http.HttpException

Throws:

IOException

org.apache.http.HttpException

consumeContent

public void consumeContent(org.apache.http.nio.ContentDecoder decoder,
 org.apache.http.nio.IOControl ioctrl)
                    throws IOException

Throws:

IOException

responseCompleted

public void responseCompleted()
                       throws IOException,
org.apache.http.HttpException

Throws:

IOException

org.apache.http.HttpException

inputTerminated

public void inputTerminated()

abortConnection

public void abortConnection()