org.apache.sandesha2.util
Class AcknowledgementManager

java.lang.Object
  extended by org.apache.sandesha2.util.AcknowledgementManager

public class AcknowledgementManager
extends java.lang.Object

Contains logic for managing acknowledgements.


Constructor Summary
AcknowledgementManager()
           
 
Method Summary
static void addAckBeanEntry(RMMsgContext ackRMMsgContext, java.lang.String sequenceId, long timeToSend, StorageManager storageManager)
           
static RMMsgContext generateAckMessage(RMMsgContext referenceRMMessage, RMDBean rmdBean, java.lang.String sequenceId, StorageManager storageManager, boolean serverSide)
           
static Transaction piggybackAcksIfPresent(RMMsgContext rmMessageContext, StorageManager storageManager, Transaction transaction)
          Piggybacks any available acks of the same sequence to the given application message.
static void sendAckNow(RMMsgContext ackRMMsgContext)
           
static boolean verifySequenceCompletion(RangeString ackRanges, 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 Transaction piggybackAcksIfPresent(RMMsgContext rmMessageContext,
                                                 StorageManager storageManager,
                                                 Transaction transaction)
                                          throws SandeshaException
Piggybacks any available acks of the same sequence to the given application message.

Parameters:
applicationRMMsgContext -
Throws:
SandeshaException

generateAckMessage

public static RMMsgContext generateAckMessage(RMMsgContext referenceRMMessage,
                                              RMDBean rmdBean,
                                              java.lang.String sequenceId,
                                              StorageManager storageManager,
                                              boolean serverSide)
                                       throws org.apache.axis2.AxisFault
Parameters:
referenceRMMessage -
sequencePropertyKey -
sequenceId -
storageManager -
makeResponse - Some work will be done to make the new ack message the response of the reference message.
Returns:
Throws:
org.apache.axis2.AxisFault

verifySequenceCompletion

public static boolean verifySequenceCompletion(RangeString ackRanges,
                                               long lastMessageNo)

addAckBeanEntry

public static void addAckBeanEntry(RMMsgContext ackRMMsgContext,
                                   java.lang.String sequenceId,
                                   long timeToSend,
                                   StorageManager storageManager)
                            throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault

sendAckNow

public static void sendAckNow(RMMsgContext ackRMMsgContext)
                       throws org.apache.axis2.AxisFault
Throws:
org.apache.axis2.AxisFault


Copyright © 2007 Apache Web Services Project. All Rights Reserved.