cgl.narada.service.reliable
Interface RdEntityActuatorService

All Superinterfaces:

Service

public interface RdEntityActuatorService
extends Service

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.

Method Summary

void	issueProfileUpdateRequest(Profile profile, boolean addProfile, ConsumerConstraints consumerConstraints)
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	syncPointHasBeenAdvanced(int entityId, int templateId, long advanceSync)
void	terminateService() Terminate the service

Methods inherited from interface cgl.narada.service.Service

deregisterServiceExceptionListener, deregisterServiceNotificationListener, getEventTypesHandled, getServiceDescription, getServicesPerformed, handleEvent, isStarted, isStopped, loadService, performService, registerServiceExceptionListener, registerServiceNotificationListener, servicePerformed, startService, stopService

Method Detail

processRetransmittedEvent

void processRetransmittedEvent(RdRetransmissionServiceEvent retransmittedEvent)
                               throws ServiceException

Throws:

ServiceException

processConstructedQosEvent

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

syncPointHasBeenAdvanced

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

processArchivalNotificationForEntity

void processArchivalNotificationForEntity(Object entityKey,
                                          RdArchivalServiceNotification archNotification)
                                          throws ServiceException

Throws:

ServiceException

issueRecoveryRequest

void issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
                          throws ServiceException

Throws:

ServiceException

processRecoveryResponse

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

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

Throws:

ServiceException

processProfileUpdateResponse

void processProfileUpdateResponse(RdProfileUpdateResponse profileUpdateResponse)
                                  throws ServiceException

Throws:

ServiceException

terminateService

void terminateService()
                      throws ServiceException

Terminate the service

Throws:

ServiceException