|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.axis2.handlers.AbstractHandler org.apache.synapse.transport.nhttp.HttpCoreNIOSender
public class HttpCoreNIOSender
NIO transport sender for Axis2 based on HttpCore and NIO extensions
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler |
---|
Handler.InvocationResponse |
Field Summary |
---|
Fields inherited from class org.apache.axis2.handlers.AbstractHandler |
---|
handlerDesc |
Constructor Summary | |
---|---|
HttpCoreNIOSender()
|
Method Summary | |
---|---|
void |
cleanup(MessageContext msgContext)
|
int |
getActiveThreadCount()
Returns the number of active threads processing messages |
double |
getAvgSizeReceived()
|
double |
getAvgSizeSent()
|
long |
getBytesReceived()
|
long |
getBytesSent()
|
protected org.apache.http.nio.reactor.IOEventDispatch |
getEventDispatch(org.apache.http.nio.NHttpClientHandler handler,
SSLContext sslContext,
org.apache.http.impl.nio.reactor.SSLIOSessionHandler sslIOSessionHandler,
org.apache.http.params.HttpParams params,
TransportOutDescription trpOut)
Return the IOEventDispatch implementation to be used. |
long |
getFaultsReceiving()
|
long |
getFaultsSending()
|
long |
getLastResetTime()
|
long |
getMaxSizeReceived()
|
long |
getMaxSizeSent()
|
long |
getMessagesReceived()
|
long |
getMessagesSent()
|
long |
getMetricsWindow()
|
long |
getMinSizeReceived()
|
long |
getMinSizeSent()
|
int |
getQueueSize()
Returns the number of requestes queued in the thread pool |
Map |
getResponseCodeTable()
|
protected SSLContext |
getSSLContext(TransportOutDescription transportOut)
Always return null, as this implementation does not support outgoing SSL |
protected org.apache.http.impl.nio.reactor.SSLIOSessionHandler |
getSSLIOSessionHandler(TransportOutDescription transportOut)
Create the SSL IO Session handler to be used by this listener |
long |
getTimeoutsReceiving()
|
long |
getTimeoutsSending()
|
void |
init(ConfigurationContext cfgCtx,
TransportOutDescription transportOut)
Initialize the transport sender, and execute reactor in new seperate thread |
Handler.InvocationResponse |
invoke(MessageContext msgContext)
transport sender invocation from Axis2 core |
void |
maintenenceShutdown(long millis)
|
void |
pause()
|
void |
resetStatistics()
|
void |
resume()
|
void |
stop()
|
Methods inherited from class org.apache.axis2.handlers.AbstractHandler |
---|
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.axis2.engine.Handler |
---|
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init |
Constructor Detail |
---|
public HttpCoreNIOSender()
Method Detail |
---|
public void init(ConfigurationContext cfgCtx, TransportOutDescription transportOut) throws AxisFault
init
in interface TransportSender
cfgCtx
- the Axis2 configuration contexttransportOut
- the description of the http/s transport from Axis2 configuration
AxisFault
- thrown on an errorprotected org.apache.http.nio.reactor.IOEventDispatch getEventDispatch(org.apache.http.nio.NHttpClientHandler handler, SSLContext sslContext, org.apache.http.impl.nio.reactor.SSLIOSessionHandler sslIOSessionHandler, org.apache.http.params.HttpParams params, TransportOutDescription trpOut) throws AxisFault
handler
- The NHTTP client handler instancesslContext
- SSL context used by the sender or nullsslIOSessionHandler
- SSL session handler or nullparams
- HTTP parameterstrpOut
- Transport out description
AxisFault
- on errorprotected SSLContext getSSLContext(TransportOutDescription transportOut) throws AxisFault
transportOut
- The transport out description
AxisFault
- on errorprotected org.apache.http.impl.nio.reactor.SSLIOSessionHandler getSSLIOSessionHandler(TransportOutDescription transportOut) throws AxisFault
transportOut
- Transport out description
AxisFault
- on errorpublic Handler.InvocationResponse invoke(MessageContext msgContext) throws AxisFault
invoke
in interface Handler
msgContext
- message to be sent
AxisFault
- on errorpublic void cleanup(MessageContext msgContext) throws AxisFault
cleanup
in interface TransportSender
AxisFault
public void stop()
stop
in interface TransportSender
public void pause() throws AxisFault
pause
in interface org.apache.axis2.transport.base.ManagementSupport
AxisFault
public void resume() throws AxisFault
resume
in interface org.apache.axis2.transport.base.ManagementSupport
AxisFault
public void maintenenceShutdown(long millis) throws AxisFault
maintenenceShutdown
in interface org.apache.axis2.transport.base.ManagementSupport
AxisFault
public int getActiveThreadCount()
getActiveThreadCount
in interface org.apache.axis2.transport.base.ManagementSupport
public int getQueueSize()
getQueueSize
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMessagesReceived()
getMessagesReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getFaultsReceiving()
getFaultsReceiving
in interface org.apache.axis2.transport.base.ManagementSupport
public long getBytesReceived()
getBytesReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMessagesSent()
getMessagesSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getFaultsSending()
getFaultsSending
in interface org.apache.axis2.transport.base.ManagementSupport
public long getBytesSent()
getBytesSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getTimeoutsReceiving()
getTimeoutsReceiving
in interface org.apache.axis2.transport.base.ManagementSupport
public long getTimeoutsSending()
getTimeoutsSending
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMinSizeReceived()
getMinSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMaxSizeReceived()
getMaxSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public double getAvgSizeReceived()
getAvgSizeReceived
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMinSizeSent()
getMinSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMaxSizeSent()
getMaxSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public double getAvgSizeSent()
getAvgSizeSent
in interface org.apache.axis2.transport.base.ManagementSupport
public Map getResponseCodeTable()
getResponseCodeTable
in interface org.apache.axis2.transport.base.ManagementSupport
public void resetStatistics()
resetStatistics
in interface org.apache.axis2.transport.base.ManagementSupport
public long getLastResetTime()
getLastResetTime
in interface org.apache.axis2.transport.base.ManagementSupport
public long getMetricsWindow()
getMetricsWindow
in interface org.apache.axis2.transport.base.ManagementSupport
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |