cgl.narada.service.reliable.impl
Class RdsEventPercolator

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

public class RdsEventPercolator
extends Object

This class is responsible to keep tracking of NBEvents and corresponding CompanionEvents

Constructor Summary

RdsEventPercolator(ReliableDeliveryServiceImpl rdsService, StorageService storageService)

Method Summary

CompanionDbInfo	getReadyEventInfo()
NBEvent	getReadyNBEvent(EventID eventId)
boolean	hasEventsAvailableForStorage()
void	printEntityCatenations()
void	processCompanionEvent(RdCompanionEntityEvent companionEvent)
void	processPublishedEvent(NBEvent nbEvent)
void	processRepublishedEvent(RdRepublishedEntityEvent republishedEvent)
void	yankEventOffReleaseBuffers(CompanionDbInfo companionDbInfo) Removes an event from the release buffers after it has been stored to stable storage.

Methods inherited from class java.lang.Object

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

Constructor Detail

RdsEventPercolator

public RdsEventPercolator(ReliableDeliveryServiceImpl rdsService,
                          StorageService storageService)
                   throws ServiceException

Throws:

ServiceException

Method Detail

processCompanionEvent

public void processCompanionEvent(RdCompanionEntityEvent companionEvent)

hasEventsAvailableForStorage

public boolean hasEventsAvailableForStorage()

getReadyEventInfo

public CompanionDbInfo getReadyEventInfo()

getReadyNBEvent

public NBEvent getReadyNBEvent(EventID eventId)

processPublishedEvent

public void processPublishedEvent(NBEvent nbEvent)

processRepublishedEvent

public void processRepublishedEvent(RdRepublishedEntityEvent republishedEvent)

yankEventOffReleaseBuffers

public void yankEventOffReleaseBuffers(CompanionDbInfo companionDbInfo)

Removes an event from the release buffers after it has been stored to stable storage. We also proceed to issue acknowledgements regarding this storage

printEntityCatenations

public void printEntityCatenations()