Class HttpCoreNIOSender
- java.lang.Object
-
- org.apache.axis2.handlers.AbstractHandler
-
- org.apache.synapse.transport.nhttp.HttpCoreNIOSender
-
- All Implemented Interfaces:
org.apache.axis2.engine.Handler
,org.apache.axis2.transport.base.ManagementSupport
,org.apache.axis2.transport.TransportSender
- Direct Known Subclasses:
HttpCoreNIOSSLSender
public class HttpCoreNIOSender extends org.apache.axis2.handlers.AbstractHandler implements org.apache.axis2.transport.TransportSender, org.apache.axis2.transport.base.ManagementSupport
NIO transport sender for Axis2 based on HttpCore and NIO extensions
-
-
Constructor Summary
Constructors Constructor Description HttpCoreNIOSender()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cleanup(org.apache.axis2.context.MessageContext msgContext)
int
getActiveThreadCount()
Returns the number of active threads processing messagesdouble
getAvgSizeReceived()
double
getAvgSizeSent()
long
getBytesReceived()
long
getBytesSent()
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 poolMap
getResponseCodeTable()
long
getTimeoutsReceiving()
long
getTimeoutsSending()
void
init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut)
Initialize the transport sender, and execute reactor in new separate threadprotected ClientConnFactoryBuilder
initConnFactoryBuilder(org.apache.axis2.description.TransportOutDescription transportOut, org.apache.axis2.context.ConfigurationContext configurationContext)
org.apache.axis2.engine.Handler.InvocationResponse
invoke(org.apache.axis2.context.MessageContext msgContext)
transport sender invocation from Axis2 corevoid
maintenenceShutdown(long millis)
void
pause()
void
reload(org.apache.axis2.description.TransportOutDescription transportOut)
Reload SSL configurations and reset all connectionsvoid
resetStatistics()
void
resume()
void
stop()
-
Methods inherited from class org.apache.axis2.handlers.AbstractHandler
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString
-
-
-
-
Method Detail
-
initConnFactoryBuilder
protected ClientConnFactoryBuilder initConnFactoryBuilder(org.apache.axis2.description.TransportOutDescription transportOut, org.apache.axis2.context.ConfigurationContext configurationContext) throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
-
init
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
Initialize the transport sender, and execute reactor in new separate thread- Specified by:
init
in interfaceorg.apache.axis2.transport.TransportSender
- Parameters:
cfgCtx
- the Axis2 configuration contexttransportOut
- the description of the http/s transport from Axis2 configuration- Throws:
org.apache.axis2.AxisFault
- thrown on an error
-
invoke
public org.apache.axis2.engine.Handler.InvocationResponse invoke(org.apache.axis2.context.MessageContext msgContext) throws org.apache.axis2.AxisFault
transport sender invocation from Axis2 core- Specified by:
invoke
in interfaceorg.apache.axis2.engine.Handler
- Parameters:
msgContext
- message to be sent- Returns:
- the invocation response (always InvocationResponse.CONTINUE)
- Throws:
org.apache.axis2.AxisFault
- on error
-
cleanup
public void cleanup(org.apache.axis2.context.MessageContext msgContext) throws org.apache.axis2.AxisFault
- Specified by:
cleanup
in interfaceorg.apache.axis2.transport.TransportSender
- Throws:
org.apache.axis2.AxisFault
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.axis2.transport.TransportSender
-
pause
public void pause() throws org.apache.axis2.AxisFault
- Specified by:
pause
in interfaceorg.apache.axis2.transport.base.ManagementSupport
- Throws:
org.apache.axis2.AxisFault
-
resume
public void resume() throws org.apache.axis2.AxisFault
- Specified by:
resume
in interfaceorg.apache.axis2.transport.base.ManagementSupport
- Throws:
org.apache.axis2.AxisFault
-
maintenenceShutdown
public void maintenenceShutdown(long millis) throws org.apache.axis2.AxisFault
- Specified by:
maintenenceShutdown
in interfaceorg.apache.axis2.transport.base.ManagementSupport
- Throws:
org.apache.axis2.AxisFault
-
getActiveThreadCount
public int getActiveThreadCount()
Returns the number of active threads processing messages- Specified by:
getActiveThreadCount
in interfaceorg.apache.axis2.transport.base.ManagementSupport
- Returns:
- number of active threads processing messages
-
getQueueSize
public int getQueueSize()
Returns the number of requestes queued in the thread pool- Specified by:
getQueueSize
in interfaceorg.apache.axis2.transport.base.ManagementSupport
- Returns:
- queue size
-
getMessagesReceived
public long getMessagesReceived()
- Specified by:
getMessagesReceived
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getFaultsReceiving
public long getFaultsReceiving()
- Specified by:
getFaultsReceiving
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getBytesReceived
public long getBytesReceived()
- Specified by:
getBytesReceived
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMessagesSent
public long getMessagesSent()
- Specified by:
getMessagesSent
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getFaultsSending
public long getFaultsSending()
- Specified by:
getFaultsSending
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getBytesSent
public long getBytesSent()
- Specified by:
getBytesSent
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getTimeoutsReceiving
public long getTimeoutsReceiving()
- Specified by:
getTimeoutsReceiving
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getTimeoutsSending
public long getTimeoutsSending()
- Specified by:
getTimeoutsSending
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMinSizeReceived
public long getMinSizeReceived()
- Specified by:
getMinSizeReceived
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMaxSizeReceived
public long getMaxSizeReceived()
- Specified by:
getMaxSizeReceived
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getAvgSizeReceived
public double getAvgSizeReceived()
- Specified by:
getAvgSizeReceived
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMinSizeSent
public long getMinSizeSent()
- Specified by:
getMinSizeSent
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMaxSizeSent
public long getMaxSizeSent()
- Specified by:
getMaxSizeSent
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getAvgSizeSent
public double getAvgSizeSent()
- Specified by:
getAvgSizeSent
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getResponseCodeTable
public Map getResponseCodeTable()
- Specified by:
getResponseCodeTable
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
resetStatistics
public void resetStatistics()
- Specified by:
resetStatistics
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getLastResetTime
public long getLastResetTime()
- Specified by:
getLastResetTime
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
getMetricsWindow
public long getMetricsWindow()
- Specified by:
getMetricsWindow
in interfaceorg.apache.axis2.transport.base.ManagementSupport
-
reload
public void reload(org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
Reload SSL configurations and reset all connections- Parameters:
transportOut
- TransportOutDescriptin of the configuration- Throws:
org.apache.axis2.AxisFault
-
-