org.apache.sandesha2.util
Class AcknowledgementManager

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

public class AcknowledgementManager
extends java.lang.Object

Contains logic for managing acknowledgements.

Author:
Chamikara Jayalath

Constructor Summary
AcknowledgementManager()
           
 
Method Summary
static RMMsgContext generateAckMessage(RMMsgContext referenceRMMessage, java.lang.String sequenceID)
           
static java.util.ArrayList getClientCompletedMessagesList(java.lang.String sequenceID, SequencePropertyBeanMgr seqPropMgr)
          this is used to get the acked messages of a sequence.
static java.util.ArrayList getServerCompletedMessagesList(java.lang.String sequenceID, SequencePropertyBeanMgr seqPropMgr)
           
static void piggybackAcksIfPresent(RMMsgContext rmMessageContext)
          Piggybacks any available acks of the same sequence to the given application message.
static boolean verifySequenceCompletion(java.util.Iterator ackRangesIterator, long lastMessageNo)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AcknowledgementManager

public AcknowledgementManager()
Method Detail

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.