org.apache.sandesha2.msgprocessors
Class ApplicationMsgProcessor

java.lang.Object
  extended byorg.apache.sandesha2.msgprocessors.ApplicationMsgProcessor
All Implemented Interfaces:
MsgProcessor

public class ApplicationMsgProcessor
extends java.lang.Object
implements MsgProcessor

Responsible for processing an incoming Application message.


Constructor Summary
ApplicationMsgProcessor()
           
 
Method Summary
 void addCreateSequenceMessage(RMMsgContext referenceRMMsg, java.lang.String sequencePropertyKey, java.lang.String internalSequenceId, org.apache.axis2.addressing.EndpointReference acksTo, StorageManager storageManager)
           
 boolean processInMessage(RMMsgContext rmMsgCtx)
           
 boolean processOutMessage(RMMsgContext rmMsgCtx)
           
 org.apache.axis2.addressing.EndpointReference resolveAcksToValue(RMMsgContext rmMsgCtx, java.lang.String addressingAnonymousURI)
           
 void sendAckIfNeeded(RMMsgContext rmMsgCtx, java.lang.String messagesStr, StorageManager storageManager)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ApplicationMsgProcessor

public ApplicationMsgProcessor()
Method Detail

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.