cgl.narada.service.reliable.impl
Class RdEntityActuatorImpl

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

All Implemented Interfaces:

RdDebugFlags

public class RdEntityActuatorImpl
extends Object
implements RdDebugFlags

This class provides a set of core functions that service implementations need to satisfy. All services within the system need to conform to this interface.

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

RdEntityActuatorImpl(QosServiceImpl qosServiceImpl)

Method Summary

void	issueProfileUpdateRequest(Profile profile, boolean addProfile, ConsumerConstraints consumerConstraints) end processRecoveryResponse()
void	issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
void	processArchivalNotificationForEntity(Object entityKey, RdArchivalServiceNotification archNotification)
void	processConstructedQosEvent(QosEvent qosEvent) Upong receipt of a NORMAL nbEvent, the qosService constructs a QosEvent if there were any consumerConstraints specified.
void	processProfileUpdateResponse(RdProfileUpdateResponse profileUpdateResponse)
void	processRecoveryResponse(RdRecoveryResponse recoveryResponse) Subscribe the relevant consumer to the set of previously registered profiles based on information encapsulated in the recovery response
void	processRetransmittedEvent(RdRetransmissionServiceEvent retransmittedEvent)
void	qosEventAvailableForRelease(QosEvent qosEvent, RdArchivalServiceNotification archNotification)
void	syncPointHasBeenAdvanced(int entityId, int templateId, long advanceSync)
void	terminateService()

Methods inherited from class java.lang.Object

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

Constructor Detail

RdEntityActuatorImpl

public RdEntityActuatorImpl(QosServiceImpl qosServiceImpl)

Method Detail

terminateService

public void terminateService()
                      throws ServiceException

Throws:

ServiceException

processRetransmittedEvent

public void processRetransmittedEvent(RdRetransmissionServiceEvent retransmittedEvent)
                               throws ServiceException

Throws:

ServiceException

processConstructedQosEvent

public void processConstructedQosEvent(QosEvent qosEvent)
                                throws ServiceException

Upong receipt of a NORMAL nbEvent, the qosService constructs a QosEvent if there were any consumerConstraints specified. This event is then routed here pending satisfaction of consumer constraints

Throws:

ServiceException

qosEventAvailableForRelease

public void qosEventAvailableForRelease(QosEvent qosEvent,
                                        RdArchivalServiceNotification archNotification)

syncPointHasBeenAdvanced

public void syncPointHasBeenAdvanced(int entityId,
                                     int templateId,
                                     long advanceSync)

processArchivalNotificationForEntity

public void processArchivalNotificationForEntity(Object entityKey,
                                                 RdArchivalServiceNotification archNotification)
                                          throws ServiceException

Throws:

ServiceException

issueRecoveryRequest

public void issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
                          throws ServiceException

Throws:

ServiceException

processRecoveryResponse

public void processRecoveryResponse(RdRecoveryResponse recoveryResponse)
                             throws ServiceException

Subscribe the relevant consumer to the set of previously registered profiles based on information encapsulated in the recovery response

Throws:

ServiceException

issueProfileUpdateRequest

public void issueProfileUpdateRequest(Profile profile,
                                      boolean addProfile,
                                      ConsumerConstraints consumerConstraints)
                               throws ServiceException

end processRecoveryResponse()

Throws:

ServiceException

processProfileUpdateResponse

public void processProfileUpdateResponse(RdProfileUpdateResponse profileUpdateResponse)
                                  throws ServiceException

Throws:

ServiceException