cgl.narada.service.reliable.impl
Class PublisherPercolator

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


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