cgl.narada.service.reliable.impl
Class RdFragmentationHelper

java.lang.Object
  extended by cgl.narada.service.reliable.impl.RdFragmentationHelper
All Implemented Interfaces:
RdDebugFlags

public class RdFragmentationHelper
extends Object
implements RdDebugFlags


Field Summary
 
Fields inherited from interface cgl.narada.service.reliable.impl.RdDebugFlags
InvoicerThread_Debug, NakProcessor_Debug, PublisherPercolator_Debug, RdEntityActuatorImpl_Debug, RdFragmentationHelper_Debug, RdPublishingEntityImpl_Debug, SubscriberPercolator_Debug
 
Constructor Summary
RdFragmentationHelper(QosServiceImpl qosServiceImpl)
           
 
Method Summary
 void catenationNumberAssigned(NBEvent fragmentedEvent, int catenationNumber)
          Keeps track of the catenation number that has been assigned to individual fragments
 void drainPayloadFromEvent(NBEvent fragmentedEvent)
           
 void fragmentStoredReliably(NBEvent fragmentedEvent)
           
 void onRecovery(int publisherCatenationNum)
          After recovery, we need to make sure that any pending fragments of files need to be sent across
 void refillPayloadIntoEvent(NBEvent fragmentedEvent)
          If there is a retransmission request and the event is a fragmented one, we need to retrieve this informtion from a file and then add this to the payload
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RdFragmentationHelper

public RdFragmentationHelper(QosServiceImpl qosServiceImpl)
Method Detail

onRecovery

public void onRecovery(int publisherCatenationNum)
                throws ServiceException
After recovery, we need to make sure that any pending fragments of files need to be sent across

Throws:
ServiceException

drainPayloadFromEvent

public void drainPayloadFromEvent(NBEvent fragmentedEvent)

refillPayloadIntoEvent

public void refillPayloadIntoEvent(NBEvent fragmentedEvent)
                            throws ServiceException
If there is a retransmission request and the event is a fragmented one, we need to retrieve this informtion from a file and then add this to the payload

Throws:
ServiceException

catenationNumberAssigned

public void catenationNumberAssigned(NBEvent fragmentedEvent,
                                     int catenationNumber)
                              throws ServiceException
Keeps track of the catenation number that has been assigned to individual fragments

Throws:
ServiceException

fragmentStoredReliably

public void fragmentStoredReliably(NBEvent fragmentedEvent)
                            throws ServiceException
Throws:
ServiceException


For comments and suggestions please send e-mail to The NaradaBrokering Project