org.apache.sandesha2.util
Class SequenceManager

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

public class SequenceManager
extends java.lang.Object

This is used to set up a new sequence, both at the sending side and the receiving side.


Constructor Summary
SequenceManager()
           
 
Method Summary
static long getLastActivatedTime(java.lang.String propertyKey, StorageManager storageManager)
           
static long getOutGoingSequenceAckedMessageCount(java.lang.String sequencePropertyKey, StorageManager storageManager)
           
static boolean hasSequenceTimedOut(java.lang.String propertyKey, RMMsgContext rmMsgCtx, StorageManager storageManager)
           
static boolean isIncomingSequenceCompleted(java.lang.String sequenceID, StorageManager storageManager)
           
static boolean isOutGoingSequenceCompleted(java.lang.String internalSequenceID, StorageManager storageManager)
           
 void removeSequence(java.lang.String sequence)
           
static void setupNewClientSequence(org.apache.axis2.context.MessageContext firstAplicationMsgCtx, java.lang.String sequencePropertyKey, java.lang.String specVersion, StorageManager storageManager)
           
static java.lang.String setupNewSequence(RMMsgContext createSequenceMsg, StorageManager storageManager)
           
static void updateLastActivatedTime(java.lang.String sequencePropertyKey, StorageManager storageManager)
          Takes the internalSeqID as the param.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SequenceManager

public SequenceManager()
Method Detail

setupNewSequence

public static java.lang.String setupNewSequence(RMMsgContext createSequenceMsg,
                                                StorageManager storageManager)
                                         throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault

removeSequence

public void removeSequence(java.lang.String sequence)

setupNewClientSequence

public static void setupNewClientSequence(org.apache.axis2.context.MessageContext firstAplicationMsgCtx,
                                          java.lang.String sequencePropertyKey,
                                          java.lang.String specVersion,
                                          StorageManager storageManager)
                                   throws SandeshaException
Throws:
SandeshaException

updateLastActivatedTime

public static void updateLastActivatedTime(java.lang.String sequencePropertyKey,
                                           StorageManager storageManager)
                                    throws SandeshaException
Takes the internalSeqID as the param. Not the sequenceID.

Throws:
SandeshaException

getLastActivatedTime

public static long getLastActivatedTime(java.lang.String propertyKey,
                                        StorageManager storageManager)
                                 throws SandeshaException
Throws:
SandeshaException

hasSequenceTimedOut

public static boolean hasSequenceTimedOut(java.lang.String propertyKey,
                                          RMMsgContext rmMsgCtx,
                                          StorageManager storageManager)
                                   throws SandeshaException
Throws:
SandeshaException

getOutGoingSequenceAckedMessageCount

public static long getOutGoingSequenceAckedMessageCount(java.lang.String sequencePropertyKey,
                                                        StorageManager storageManager)
                                                 throws SandeshaException
Throws:
SandeshaException

isOutGoingSequenceCompleted

public static boolean isOutGoingSequenceCompleted(java.lang.String internalSequenceID,
                                                  StorageManager storageManager)
                                           throws SandeshaException
Throws:
SandeshaException

isIncomingSequenceCompleted

public static boolean isIncomingSequenceCompleted(java.lang.String sequenceID,
                                                  StorageManager storageManager)
                                           throws SandeshaException
Throws:
SandeshaException


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