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.
- Author:
- Chamikara Jayalath
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)
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 sequenceID)
throws SandeshaException
- Throws:
SandeshaException
verifySequenceCompletion
public static boolean verifySequenceCompletion(java.util.Iterator ackRangesIterator,
long lastMessageNo)
Copyright © 2005-2006 Apache Web Services. All Rights Reserved.