org.apache.sandesha2.util
Class SequenceManager
java.lang.Object
org.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.
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 |
SequenceManager
public SequenceManager()
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.