org.wso2.mercury.workers
Class MessageWorker
java.lang.Object
org.wso2.mercury.workers.MessageWorker
- All Implemented Interfaces:
- java.lang.Runnable
public class MessageWorker
- extends java.lang.Object
- implements java.lang.Runnable
this class is used to send a message by forking a
new thread.
Constructor Summary |
MessageWorker(org.apache.axis2.context.MessageContext messageContext,
boolean isResume)
|
MessageWorker(org.apache.axis2.context.MessageContext messageContext,
org.apache.axis2.context.MessageContext responseMessageContext,
boolean resume,
boolean invokeAsAnonClient)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageWorker
public MessageWorker(org.apache.axis2.context.MessageContext messageContext,
boolean isResume)
MessageWorker
public MessageWorker(org.apache.axis2.context.MessageContext messageContext,
org.apache.axis2.context.MessageContext responseMessageContext,
boolean resume,
boolean invokeAsAnonClient)
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
handleResponse
protected void handleResponse(org.apache.axis2.context.MessageContext responseMessageContext)
throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
isInvokeAsAnonClient
public boolean isInvokeAsAnonClient()
setInvokeAsAnonClient
public void setInvokeAsAnonClient(boolean invokeAsAnonClient)
getRmsSequence
public RMSSequence getRmsSequence()
setRmsSequence
public void setRmsSequence(RMSSequence rmsSequence)
~~~~~~~~~~~~~~~~~~~ Mercury ~~~~~~~~~~~~~~~~~~~~~