|
||||||||||
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.axis2.transport.base.AbstractTransportSender
public abstract class AbstractTransportSender
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.axis2.engine.Handler |
---|
org.apache.axis2.engine.Handler.InvocationResponse |
Field Summary | |
---|---|
protected org.apache.axis2.context.ConfigurationContext |
cfgCtx
the axis2 configuration context |
protected org.apache.commons.logging.Log |
log
the reference to the actual commons logger to be used for log messages |
protected MetricsCollector |
metrics
Metrics collector for the sender |
Fields inherited from class org.apache.axis2.handlers.AbstractHandler |
---|
handlerDesc |
Constructor Summary | |
---|---|
protected |
AbstractTransportSender()
A constructor that makes subclasses pick up the correct logger |
Method Summary | |
---|---|
void |
cleanup(org.apache.axis2.context.MessageContext msgContext)
|
org.apache.axis2.context.MessageContext |
createResponseMessageContext(org.apache.axis2.context.MessageContext outMsgCtx)
Create a new axis MessageContext for an incoming response message through this transport, for the given outgoing message |
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()
Return the number of requests queued in the thread pool |
java.util.Map |
getResponseCodeTable()
|
long |
getTimeoutsReceiving()
|
long |
getTimeoutsSending()
|
java.lang.String |
getTransportName()
|
protected void |
handleException(java.lang.String msg)
|
protected void |
handleException(java.lang.String msg,
java.lang.Exception e)
|
void |
handleIncomingMessage(org.apache.axis2.context.MessageContext msgCtx,
java.util.Map trpHeaders,
java.lang.String soapAction,
java.lang.String contentType)
Process a new incoming message (Response) through the axis engine |
void |
init(org.apache.axis2.context.ConfigurationContext cfgCtx,
org.apache.axis2.description.TransportOutDescription transportOut)
Initialize the generic transport sender. |
org.apache.axis2.engine.Handler.InvocationResponse |
invoke(org.apache.axis2.context.MessageContext msgContext)
|
protected void |
logException(java.lang.String msg,
java.lang.Exception e)
|
void |
maintenenceShutdown(long millis)
|
void |
pause()
|
void |
resetStatistics()
|
void |
resume()
|
abstract void |
sendMessage(org.apache.axis2.context.MessageContext msgCtx,
java.lang.String targetEPR,
org.apache.axis2.transport.OutTransportInfo outTransportInfo)
|
void |
stop()
|
protected boolean |
waitForSynchronousResponse(org.apache.axis2.context.MessageContext msgCtx)
Should the transport sender wait for a synchronous response to be received? |
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 |
Field Detail |
---|
protected org.apache.commons.logging.Log log
protected org.apache.axis2.context.ConfigurationContext cfgCtx
protected MetricsCollector metrics
Constructor Detail |
---|
protected AbstractTransportSender()
Method Detail |
---|
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 axis configuration contexttransportOut
- the transport-out description
org.apache.axis2.AxisFault
- on errorpublic void stop()
stop
in interface org.apache.axis2.transport.TransportSender
public 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 abstract void sendMessage(org.apache.axis2.context.MessageContext msgCtx, java.lang.String targetEPR, org.apache.axis2.transport.OutTransportInfo outTransportInfo) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public 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
org.apache.axis2.AxisFault
public void handleIncomingMessage(org.apache.axis2.context.MessageContext msgCtx, java.util.Map trpHeaders, java.lang.String soapAction, java.lang.String contentType)
msgCtx
- the axis MessageContexttrpHeaders
- the map containing transport level message headerssoapAction
- the optional soap action or nullcontentType
- the optional content-type for the messagepublic org.apache.axis2.context.MessageContext createResponseMessageContext(org.apache.axis2.context.MessageContext outMsgCtx)
outMsgCtx
- the outgoing message
protected boolean waitForSynchronousResponse(org.apache.axis2.context.MessageContext msgCtx)
msgCtx
- the outgoing message context
public java.lang.String getTransportName()
protected void handleException(java.lang.String msg, java.lang.Exception e) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
protected void handleException(java.lang.String msg) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
protected void logException(java.lang.String msg, java.lang.Exception e)
public void pause() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void resume() throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public void maintenenceShutdown(long millis) throws org.apache.axis2.AxisFault
org.apache.axis2.AxisFault
public int getActiveThreadCount()
public int getQueueSize()
public long getMessagesReceived()
public long getFaultsReceiving()
public long getBytesReceived()
public long getMessagesSent()
public long getFaultsSending()
public long getBytesSent()
public long getTimeoutsReceiving()
public long getTimeoutsSending()
public long getMinSizeReceived()
public long getMaxSizeReceived()
public double getAvgSizeReceived()
public long getMinSizeSent()
public long getMaxSizeSent()
public double getAvgSizeSent()
public java.util.Map getResponseCodeTable()
public void resetStatistics()
public long getLastResetTime()
public long getMetricsWindow()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |