cgl.narada.service.reliable.impl
Class RdPublishingEntityImpl

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