cgl.narada.service.reliable.impl
Class SubscriberPercolator

java.lang.Object
  cgl.narada.service.reliable.impl.SubscriberPercolator

All Implemented Interfaces:

NBEventListener, RdDebugFlags

public class SubscriberPercolator
extends Object
implements NBEventListener, RdDebugFlags

This class is used to keep track of events/archival notifications received and also to issue ACKs and to respond to ACKService responses ALL pertaining to a SINGLE entity .

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

SubscriberPercolator(int entityId, RdEntityActuatorImpl entityActuator)

Method Summary

void	issueProfileUpdateRequest(RdProfileUpdateRequest profileUpdateRequest) Used to propagate a profile update request
void	issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
void	onEvent(NBEvent nbEvent) Upon the receipt of an event which has satisfied all the constraints, if any were provided, that needed to be satisfied prior to delivery
void	processAckResponseEvent(RdAckResponseServiceInvoiceEvent ackResponse)
void	processArchivalNotification(RdArchivalServiceNotification archNotification)
void	processProfileUpdateResponse(RdProfileUpdateResponse profileUpdateResponse)
void	processReceivedEvent(QosEvent qosEvent)
void	processRecoveryResponse(RdRecoveryResponse recoveryResponse)
void	processRetransmittedEvent(RdRetransmissionServiceEvent retransmittedEvent)
void	terminateService()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriberPercolator

public SubscriberPercolator(int entityId,
                            RdEntityActuatorImpl entityActuator)
                     throws ServiceException

Throws:

ServiceException

Method Detail

terminateService

public void terminateService()
                      throws ServiceException

Throws:

ServiceException

issueRecoveryRequest

public void issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
                          throws ServiceException

Throws:

ServiceException

processAckResponseEvent

public void processAckResponseEvent(RdAckResponseServiceInvoiceEvent ackResponse)
                             throws ServiceException

Throws:

ServiceException

processArchivalNotification

public void processArchivalNotification(RdArchivalServiceNotification archNotification)
                                 throws ServiceException

Throws:

ServiceException

processRetransmittedEvent

public void processRetransmittedEvent(RdRetransmissionServiceEvent retransmittedEvent)
                               throws ServiceException

Throws:

ServiceException

processReceivedEvent

public void processReceivedEvent(QosEvent qosEvent)

processRecoveryResponse

public void processRecoveryResponse(RdRecoveryResponse recoveryResponse)
                             throws ServiceException

Throws:

ServiceException

issueProfileUpdateRequest

public void issueProfileUpdateRequest(RdProfileUpdateRequest profileUpdateRequest)
                               throws ServiceException

Used to propagate a profile update request

Throws:

ServiceException

processProfileUpdateResponse

public void processProfileUpdateResponse(RdProfileUpdateResponse profileUpdateResponse)
                                  throws ServiceException

Throws:

ServiceException

onEvent

public void onEvent(NBEvent nbEvent)

Description copied from interface: NBEventListener

Upon the receipt of an event which has satisfied all the constraints, if any were provided, that needed to be satisfied prior to delivery

Specified by:

onEvent in interface NBEventListener