org.apache.sandesha2.util
Class RMMsgCreator

java.lang.Object
  extended byorg.apache.sandesha2.util.RMMsgCreator

public class RMMsgCreator
extends java.lang.Object

Used to create new RM messages.


Constructor Summary
RMMsgCreator()
           
 
Method Summary
static void addAckMessage(RMMsgContext applicationMsg, java.lang.String sequencePropertyKey, java.lang.String sequenceId, StorageManager storageManager)
          Adds an ack message to the given application message.
static RMMsgContext createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static RMMsgContext createCreateSeqMsg(RMMsgContext applicationRMMsg, java.lang.String sequencePropertyKey, org.apache.axis2.addressing.EndpointReference acksToEPR, StorageManager storageManager)
          Create a new CreateSeqnence message.
static RMMsgContext createCreateSeqResponseMsg(RMMsgContext createSeqMessage, org.apache.axis2.context.MessageContext outMessage, java.lang.String newSequenceID, StorageManager storageManager)
          Create a new CreateSequenceResponse message.
static RMMsgContext createMakeConnectionMessage(RMMsgContext referenceRMMessage, java.lang.String makeConnectionSeqId, java.lang.String makeConnectionAnonURI, StorageManager storageManager)
           
static RMMsgContext createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg, org.apache.axis2.context.MessageContext outMessage, StorageManager storageManager)
           
static RMMsgContext createTerminateSequenceMessage(RMMsgContext referenceRMMessage, java.lang.String sequenceId, java.lang.String sequencePropertyKey, StorageManager storageManager)
          Creates a new TerminateSequence message.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RMMsgCreator

public RMMsgCreator()
Method Detail

createCreateSeqMsg

public static RMMsgContext createCreateSeqMsg(RMMsgContext applicationRMMsg,
                                              java.lang.String sequencePropertyKey,
                                              org.apache.axis2.addressing.EndpointReference acksToEPR,
                                              StorageManager storageManager)
                                       throws org.apache.axis2.AxisFault
Create a new CreateSeqnence message.

Parameters:
applicationRMMsg -
acksToEPR -
Returns:
Throws:
SandeshaException
org.apache.axis2.AxisFault

createTerminateSequenceMessage

public static RMMsgContext createTerminateSequenceMessage(RMMsgContext referenceRMMessage,
                                                          java.lang.String sequenceId,
                                                          java.lang.String sequencePropertyKey,
                                                          StorageManager storageManager)
                                                   throws org.apache.axis2.AxisFault
Creates a new TerminateSequence message.

Parameters:
referenceRMMessage -
sequenceId -
Returns:
Throws:
SandeshaException
org.apache.axis2.AxisFault

createCreateSeqResponseMsg

public static RMMsgContext createCreateSeqResponseMsg(RMMsgContext createSeqMessage,
                                                      org.apache.axis2.context.MessageContext outMessage,
                                                      java.lang.String newSequenceID,
                                                      StorageManager storageManager)
                                               throws org.apache.axis2.AxisFault
Create a new CreateSequenceResponse message.

Parameters:
createSeqMessage -
outMessage -
newSequenceID -
Returns:
Throws:
org.apache.axis2.AxisFault

createTerminateSeqResponseMsg

public static RMMsgContext createTerminateSeqResponseMsg(RMMsgContext terminateSeqRMMsg,
                                                         org.apache.axis2.context.MessageContext outMessage,
                                                         StorageManager storageManager)
                                                  throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault

createCloseSeqResponseMsg

public static RMMsgContext createCloseSeqResponseMsg(RMMsgContext closeSeqRMMsg,
                                                     org.apache.axis2.context.MessageContext outMessage,
                                                     StorageManager storageManager)
                                              throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault

addAckMessage

public static void addAckMessage(RMMsgContext applicationMsg,
                                 java.lang.String sequencePropertyKey,
                                 java.lang.String sequenceId,
                                 StorageManager storageManager)
                          throws org.apache.axis2.AxisFault
Adds an ack message to the given application message.

Parameters:
applicationMsg -
sequenceId -
Throws:
SandeshaException
org.apache.axis2.AxisFault

createMakeConnectionMessage

public static RMMsgContext createMakeConnectionMessage(RMMsgContext referenceRMMessage,
                                                       java.lang.String makeConnectionSeqId,
                                                       java.lang.String makeConnectionAnonURI,
                                                       StorageManager storageManager)
                                                throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault


Copyright © 2005-2006 Apache Web Services. All Rights Reserved.