public class HttpCoreNIOSender
extends org.apache.axis2.handlers.AbstractHandler
implements org.apache.axis2.transport.TransportSender, org.apache.axis2.transport.base.ManagementSupport
Constructor and Description |
---|
HttpCoreNIOSender() |
Modifier and Type | Method and Description |
---|---|
void |
cleanup(org.apache.axis2.context.MessageContext msgContext) |
int |
getActiveThreadCount()
Returns the number of active threads processing messages
|
double |
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 pool
|
Map |
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 thread
|
protected ClientConnFactoryBuilder |
initConnFactoryBuilder(org.apache.axis2.description.TransportOutDescription transportOut) |
org.apache.axis2.engine.Handler.InvocationResponse |
invoke(org.apache.axis2.context.MessageContext msgContext)
transport sender invocation from Axis2 core
|
void |
maintenenceShutdown(long millis) |
void |
pause() |
void |
reload(org.apache.axis2.description.TransportOutDescription transportOut)
Reload SSL configurations and reset all connections
|
void |
resetStatistics() |
void |
resume() |
void |
stop() |
cleanup, flowComplete, getHandlerDesc, getName, getParameter, init, toString
protected ClientConnFactoryBuilder initConnFactoryBuilder(org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void init(org.apache.axis2.context.ConfigurationContext cfgCtx, org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
init
in interface org.apache.axis2.transport.TransportSender
cfgCtx
- the Axis2 configuration contexttransportOut
- the description of the http/s transport from Axis2 configurationorg.apache.axis2.AxisFault
- thrown on an errorpublic org.apache.axis2.engine.Handler.InvocationResponse invoke(org.apache.axis2.context.MessageContext msgContext) throws org.apache.axis2.AxisFault
invoke
in interface org.apache.axis2.engine.Handler
msgContext
- message to be sentorg.apache.axis2.AxisFault
- on errorpublic void cleanup(org.apache.axis2.context.MessageContext msgContext) throws org.apache.axis2.AxisFault
cleanup
in interface org.apache.axis2.transport.TransportSender
org.apache.axis2.AxisFault
public void stop()
stop
in interface org.apache.axis2.transport.TransportSender
public void pause() throws org.apache.axis2.AxisFault
pause
in interface org.apache.axis2.transport.base.ManagementSupport
org.apache.axis2.AxisFault
public void resume() throws org.apache.axis2.AxisFault
resume
in interface org.apache.axis2.transport.base.ManagementSupport
org.apache.axis2.AxisFault
public void maintenenceShutdown(long millis) throws org.apache.axis2.AxisFault
maintenenceShutdown
in interface org.apache.axis2.transport.base.ManagementSupport
org.apache.axis2.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
public void reload(org.apache.axis2.description.TransportOutDescription transportOut) throws org.apache.axis2.AxisFault
transportOut
- TransportOutDescriptin of the configurationorg.apache.axis2.AxisFault
Copyright © 2005–2017 Apache Software Foundation. All rights reserved.