org.apache.sandesha2.util
Class AcknowledgementManager
java.lang.Object
org.apache.sandesha2.util.AcknowledgementManager
- public class AcknowledgementManager
- extends java.lang.Object
Contains logic for managing acknowledgements.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AcknowledgementManager
public AcknowledgementManager()
piggybackAcksIfPresent
public static void piggybackAcksIfPresent(RMMsgContext rmMessageContext,
StorageManager storageManager)
throws SandeshaException
- Piggybacks any available acks of the same sequence to the given
application message.
- Throws:
SandeshaException
getClientCompletedMessagesList
public static java.util.ArrayList getClientCompletedMessagesList(java.lang.String sequenceID,
SequencePropertyBeanMgr seqPropMgr)
throws SandeshaException
- this is used to get the acked messages of a sequence. If this is an
outgoing message the sequenceIdentifier should be the internal
sequenceID.
- Returns:
-
- Throws:
SandeshaException
getServerCompletedMessagesList
public static java.util.ArrayList getServerCompletedMessagesList(java.lang.String sequenceID,
SequencePropertyBeanMgr seqPropMgr)
throws SandeshaException
- Throws:
SandeshaException
generateAckMessage
public static RMMsgContext generateAckMessage(RMMsgContext referenceRMMessage,
java.lang.String sequencePropertyKey,
java.lang.String sequenceId,
StorageManager storageManager)
throws org.apache.axis2.AxisFault
- Throws:
org.apache.axis2.AxisFault
verifySequenceCompletion
public static boolean verifySequenceCompletion(java.util.Iterator ackRangesIterator,
long lastMessageNo)
addFinalAcknowledgement
public static void addFinalAcknowledgement()
Copyright © 2005-2006 Apache Web Services. All Rights Reserved.