cgl.narada.service.reliable.impl
Class RdPublishingEntityImpl

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

public class RdPublishingEntityImpl
extends Object
implements NBEventListener, RdDebugFlags

This class is responsible for ensuring that entity events are published reliably


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
RdPublishingEntityImpl(QosServiceImpl qosServiceImpl, CommunicationsService communicationsService)
           
 
Method Summary
 void eventHasBeenReliablyPublished(NBEvent nbEvent)
          After the event receives a negotiation acknowledgement the indication is that the event has been successfully stored onto stable storage
 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 processNegotiationServiceEvent(RdNegotiationsServiceEvent negotiationEvent)
           
 void processRecoveryResponse(RdRecoveryResponse recoveryResponse)
           
protected  void publishEvent(NBEvent nbEvent)
           
 void publishReliably(QosEvent qosEvent)
           
 void removeEventFromQueue(NBEvent nbEvent)
          Removes an event from the queue based on the fact that event was previously published.
 void terminateService()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RdPublishingEntityImpl

public RdPublishingEntityImpl(QosServiceImpl qosServiceImpl,
                              CommunicationsService communicationsService)
                       throws ServiceException
Throws:
ServiceException
Method Detail

terminateService

public void terminateService()
                      throws ServiceException
Throws:
ServiceException

publishReliably

public void publishReliably(QosEvent qosEvent)
                     throws ServiceException
Throws:
ServiceException

publishEvent

protected void publishEvent(NBEvent nbEvent)

eventHasBeenReliablyPublished

public void eventHasBeenReliablyPublished(NBEvent nbEvent)
After the event receives a negotiation acknowledgement the indication is that the event has been successfully stored onto stable storage


removeEventFromQueue

public void removeEventFromQueue(NBEvent nbEvent)
Removes an event from the queue based on the fact that event was previously published. This method would be invoked from the publisher percolator


processNegotiationServiceEvent

public void processNegotiationServiceEvent(RdNegotiationsServiceEvent negotiationEvent)

processRecoveryResponse

public void processRecoveryResponse(RdRecoveryResponse recoveryResponse)

issueRecoveryRequest

public void issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
                          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


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