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.


Constructor Summary
AcknowledgementManager()
           
 
Method Summary
static void addFinalAcknowledgement()
           
static RMMsgContext generateAckMessage(RMMsgContext referenceRMMessage, java.lang.String sequencePropertyKey, java.lang.String sequenceId, StorageManager storageManager)
           
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, StorageManager storageManager)
          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,
                                          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.