cgl.narada.service.reliable.impl
Class PublisherPercolator

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

All Implemented Interfaces:

RdDebugFlags

public class PublisherPercolator
extends Object
implements RdDebugFlags

Keeps track of published events that have been archived onto stable storage and those that haven't been. Also facilitates retransmission of events upon receipt of a

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

PublisherPercolator(int entityId, EventProducer producer)

Method Summary

void	issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
void	processNegotiationsEvent(RdNegotiationsServiceEvent negotiationEvent)
void	processRecoveryResponse(RdRecoveryResponse recoveryResponse)
void	publishEvent(NBEvent nbEvent)
void	setFragmentationHelper(RdFragmentationHelper fragmentationHelper)

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherPercolator

public PublisherPercolator(int entityId,
                           EventProducer producer)

Method Detail

setFragmentationHelper

public void setFragmentationHelper(RdFragmentationHelper fragmentationHelper)

publishEvent

public void publishEvent(NBEvent nbEvent)
                  throws ServiceException

Throws:

ServiceException

processNegotiationsEvent

public void processNegotiationsEvent(RdNegotiationsServiceEvent negotiationEvent)

processRecoveryResponse

public void processRecoveryResponse(RdRecoveryResponse recoveryResponse)

issueRecoveryRequest

public void issueRecoveryRequest(RdRecoveryEntityRequest recoveryRequest)
                          throws ServiceException

Throws:

ServiceException