cgl.narada.service.reliable.impl
Class RdEntityActuatorImpl

java.lang.Object
  extended by 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


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