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.

Author:
Chamikara Jayalath

Constructor Summary
SequenceManager()
           
 
Method Summary
static long getLastActivatedTime(java.lang.String propertyKey, org.apache.axis2.context.ConfigurationContext configContext)
           
static long getOutGoingSequenceAckedMessageCount(java.lang.String internalSequenceID, org.apache.axis2.context.ConfigurationContext configurationContext)
           
static boolean hasSequenceTimedOut(java.lang.String propertyKey, RMMsgContext rmMsgCtx)
           
static boolean isIncomingSequenceCompleted(java.lang.String sequenceID, org.apache.axis2.context.ConfigurationContext configurationContext)
           
static boolean isOutGoingSequenceCompleted(java.lang.String internalSequenceID, org.apache.axis2.context.ConfigurationContext configurationContext)
           
 void removeSequence(java.lang.String sequence)
           
static void setupNewClientSequence(org.apache.axis2.context.MessageContext firstAplicationMsgCtx, java.lang.String internalSequenceId, java.lang.String specVersion)
           
static java.lang.String setupNewSequence(RMMsgContext createSequenceMsg)
           
static void updateLastActivatedTime(java.lang.String propertyKey, org.apache.axis2.context.ConfigurationContext configContext)
          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)
                                         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 internalSequenceId,
                                          java.lang.String specVersion)
                                   throws SandeshaException
Throws:
SandeshaException

updateLastActivatedTime

public static void updateLastActivatedTime(java.lang.String propertyKey,
                                           org.apache.axis2.context.ConfigurationContext configContext)
                                    throws SandeshaException
Takes the internalSeqID as the param. Not the sequenceID.

Parameters:
configContext -
Throws:
SandeshaException

getLastActivatedTime

public static long getLastActivatedTime(java.lang.String propertyKey,
                                        org.apache.axis2.context.ConfigurationContext configContext)
                                 throws SandeshaException
Throws:
SandeshaException

hasSequenceTimedOut

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

getOutGoingSequenceAckedMessageCount

public static long getOutGoingSequenceAckedMessageCount(java.lang.String internalSequenceID,
                                                        org.apache.axis2.context.ConfigurationContext configurationContext)
                                                 throws SandeshaException
Throws:
SandeshaException

isOutGoingSequenceCompleted

public static boolean isOutGoingSequenceCompleted(java.lang.String internalSequenceID,
                                                  org.apache.axis2.context.ConfigurationContext configurationContext)
                                           throws SandeshaException
Throws:
SandeshaException

isIncomingSequenceCompleted

public static boolean isIncomingSequenceCompleted(java.lang.String sequenceID,
                                                  org.apache.axis2.context.ConfigurationContext configurationContext)
                                           throws SandeshaException
Throws:
SandeshaException


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