public class ClientHandler extends Object implements org.apache.http.nio.NHttpClientEventHandler
| Modifier and Type | Field and Description |
|---|---|
static String |
ATTACHMENT_KEY |
static String |
AXIS2_HTTP_REQUEST |
static String |
CLIENT_CONNECTION_DEBUG |
static String |
CONNECTION_CREATION_TIME |
static String |
OUTGOING_MESSAGE_CONTEXT |
static String |
REQUEST_SOURCE_BUFFER |
static String |
RESPONSE_SINK_BUFFER |
static String |
TUNNEL_HANDLER |
| Constructor and Description |
|---|
ClientHandler(ConnectionPool connpool,
ClientConnFactory connFactory,
ProxyConfig proxyConfig,
org.apache.axis2.context.ConfigurationContext cfgCtx,
org.apache.http.params.HttpParams params,
NhttpMetricsCollector metrics)
Create an instance of this client connection handler using the Axis2 configuration
context and Http protocol parameters given
|
| Modifier and Type | Method and Description |
|---|---|
void |
closed(org.apache.http.nio.NHttpClientConnection conn)
Handle connection close events
|
void |
connected(org.apache.http.nio.NHttpClientConnection conn,
Object attachment)
Invoked when the destination is connected
|
void |
endOfInput(org.apache.http.nio.NHttpClientConnection conn) |
void |
exception(org.apache.http.nio.NHttpClientConnection conn,
Exception ex)
Handle IO errors while reading or writing to underlying channels
|
void |
exception(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.HttpException e)
Handle Http protocol violations encountered while reading from underlying channels
|
void |
execute(Runnable task) |
int |
getActiveCount() |
int |
getQueueSize() |
void |
inputReady(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.nio.ContentDecoder decoder)
Process ready input (i.e.
|
protected void |
markRequestCompletedWithError(Axis2HttpRequest axis2Request,
int errorCode,
String errorMessage,
Exception exceptionToRaise)
Mark request to send failed with error
|
void |
outputReady(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.nio.ContentEncoder encoder)
Process ready output (i.e.
|
void |
requestReady(org.apache.http.nio.NHttpClientConnection conn) |
void |
resetConnectionPool(Set<String> hostList)
Shutdown the connections of the given host:port list.
|
void |
responseReceived(org.apache.http.nio.NHttpClientConnection conn)
Process a response received for the request sent out
|
void |
setConnFactory(ClientConnFactory connFactory)
Set the given Client Connection Factory.
|
void |
stop() |
void |
submitRequest(org.apache.http.nio.NHttpClientConnection conn,
Axis2HttpRequest axis2Req)
Submit a new request over an already established connection, which has been
'kept alive'
|
void |
timeout(org.apache.http.nio.NHttpClientConnection conn)
Handle connection timeouts by shutting down the connections.
|
public static final String ATTACHMENT_KEY
public static final String TUNNEL_HANDLER
public static final String OUTGOING_MESSAGE_CONTEXT
public static final String AXIS2_HTTP_REQUEST
public static final String CLIENT_CONNECTION_DEBUG
public static final String CONNECTION_CREATION_TIME
public static final String REQUEST_SOURCE_BUFFER
public static final String RESPONSE_SINK_BUFFER
public ClientHandler(ConnectionPool connpool, ClientConnFactory connFactory, ProxyConfig proxyConfig, org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.http.params.HttpParams params, NhttpMetricsCollector metrics) throws org.apache.axis2.AxisFault
cfgCtx - the Axis2 configuration contextparams - the Http protocol parameters to adhere tometrics - statistics collection metricsorg.apache.axis2.AxisFaultpublic void requestReady(org.apache.http.nio.NHttpClientConnection conn)
throws IOException,
org.apache.http.HttpException
requestReady in interface org.apache.http.nio.NHttpClientEventHandlerIOExceptionorg.apache.http.HttpExceptionpublic void submitRequest(org.apache.http.nio.NHttpClientConnection conn,
Axis2HttpRequest axis2Req)
throws org.apache.http.ConnectionClosedException
conn - the connection to use to send the request, which has been kept openaxis2Req - the new requestorg.apache.http.ConnectionClosedException - if the connection is closed by the other partypublic void connected(org.apache.http.nio.NHttpClientConnection conn,
Object attachment)
connected in interface org.apache.http.nio.NHttpClientEventHandlerconn - the connection being processedattachment - the attachment set previouslypublic void closed(org.apache.http.nio.NHttpClientConnection conn)
closed in interface org.apache.http.nio.NHttpClientEventHandlerconn - HTTP connection to be closedpublic void timeout(org.apache.http.nio.NHttpClientConnection conn)
timeout in interface org.apache.http.nio.NHttpClientEventHandlerconn - the connection being processedpublic void exception(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.HttpException e)
conn - the connection being processede - the exception encounteredpublic void exception(org.apache.http.nio.NHttpClientConnection conn,
Exception ex)
exception in interface org.apache.http.nio.NHttpClientEventHandlerconn - the connection being processedex - the exception encounteredpublic void endOfInput(org.apache.http.nio.NHttpClientConnection conn)
throws IOException
endOfInput in interface org.apache.http.nio.NHttpClientEventHandlerIOExceptionprotected void markRequestCompletedWithError(Axis2HttpRequest axis2Request, int errorCode, String errorMessage, Exception exceptionToRaise)
axis2Request - the Axis2HttpRequest to be marked as completed with an errorerrorCode - the error code to raiseerrorMessage - the text for an error message to be returned to the MR on failureexceptionToRaise - an Exception to be returned to the MR on failurepublic void inputReady(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.nio.ContentDecoder decoder)
inputReady in interface org.apache.http.nio.NHttpClientEventHandlerconn - connection being processeddecoder - the content decoder in usepublic void outputReady(org.apache.http.nio.NHttpClientConnection conn,
org.apache.http.nio.ContentEncoder encoder)
outputReady in interface org.apache.http.nio.NHttpClientEventHandlerconn - the connection being processedencoder - the encoder in usepublic void responseReceived(org.apache.http.nio.NHttpClientConnection conn)
responseReceived in interface org.apache.http.nio.NHttpClientEventHandlerconn - the connection being processedpublic void execute(Runnable task)
public int getActiveCount()
public int getQueueSize()
public void stop()
public void setConnFactory(ClientConnFactory connFactory)
connFactory - ClientConnectionFactory instanceCopyright © 2005–2019 Apache Software Foundation. All rights reserved.