org.apache.sandesha2.msgprocessors
Class ApplicationMsgProcessor
java.lang.Object
org.apache.sandesha2.msgprocessors.ApplicationMsgProcessor
- All Implemented Interfaces:
- MsgProcessor
- public class ApplicationMsgProcessor
- extends java.lang.Object
- implements MsgProcessor
Responsible for processing an incoming Application message.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ApplicationMsgProcessor
public ApplicationMsgProcessor()
processInMessage
public boolean processInMessage(RMMsgContext rmMsgCtx)
throws org.apache.axis2.AxisFault
- Specified by:
processInMessage
in interface MsgProcessor
- Parameters:
rmMsgCtx
-
- Returns:
- true if the msg context has been paused
- Throws:
org.apache.axis2.AxisFault
sendAckIfNeeded
public void sendAckIfNeeded(RMMsgContext rmMsgCtx,
java.lang.String messagesStr,
StorageManager storageManager)
throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
processOutMessage
public boolean processOutMessage(RMMsgContext rmMsgCtx)
throws org.apache.axis2.AxisFault
- Specified by:
processOutMessage
in interface MsgProcessor
- Parameters:
rmMsgCtx
-
- Returns:
- true if the msg context has been paused
- Throws:
org.apache.axis2.AxisFault
addCreateSequenceMessage
public void addCreateSequenceMessage(RMMsgContext referenceRMMsg,
java.lang.String sequencePropertyKey,
java.lang.String internalSequenceId,
org.apache.axis2.addressing.EndpointReference acksTo,
StorageManager storageManager)
throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
resolveAcksToValue
public org.apache.axis2.addressing.EndpointReference resolveAcksToValue(RMMsgContext rmMsgCtx,
java.lang.String addressingAnonymousURI)
throws SandeshaException
- Throws:
SandeshaException
Copyright © 2005-2006 Apache Web Services. All Rights Reserved.