cgl.narada.service.reliable.impl
Class RdCommunicationsMultiplexerImpl

java.lang.Object
  java.lang.Thread
      cgl.narada.service.reliable.impl.RdCommunicationsMultiplexerImpl

All Implemented Interfaces:

Runnable

public class RdCommunicationsMultiplexerImpl
extends Thread

This class is responsible for reconstructing the byte streams and rerouting the events to the corresponding handlers.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

RdCommunicationsMultiplexerImpl()

Method Summary

void	manageReliableDeliveryExchange(NBEvent nbEvent)
void	multiplexReliableDeliveryExchange(NBEvent nbEvent)
void	onEvent(NBEvent nbEvent)
void	registerPublishingEntity(RdPublishingEntityImpl rdPublisherImpl)
void	registerRecoveryService()
void	registerReliableDeliveryService(ReliableDeliveryServiceImpl rdsImpl)
void	registerRetransmissionService()
void	registerSubscriberPercolator(SubscriberPercolator subscriberPercolator)
void	run()
void	terminateService() Terminating the service

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

RdCommunicationsMultiplexerImpl

public RdCommunicationsMultiplexerImpl()

Method Detail

registerReliableDeliveryService

public void registerReliableDeliveryService(ReliableDeliveryServiceImpl rdsImpl)
                                     throws ServiceException

Throws:

ServiceException

registerSubscriberPercolator

public void registerSubscriberPercolator(SubscriberPercolator subscriberPercolator)

registerPublishingEntity

public void registerPublishingEntity(RdPublishingEntityImpl rdPublisherImpl)
                              throws ServiceException

Throws:

ServiceException

registerRetransmissionService

public void registerRetransmissionService()

registerRecoveryService

public void registerRecoveryService()

onEvent

public void onEvent(NBEvent nbEvent)

manageReliableDeliveryExchange

public void manageReliableDeliveryExchange(NBEvent nbEvent)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

terminateService

public void terminateService()
                      throws ServiceException

Terminating the service

Throws:

ServiceException

multiplexReliableDeliveryExchange

public void multiplexReliableDeliveryExchange(NBEvent nbEvent)