cgl.narada.service.qos.impl
Class QosServiceImpl

java.lang.Object
  cgl.narada.service.qos.impl.QosServiceImpl

public class QosServiceImpl
extends Object

This class provides a set of core functions that service implementations need to satisfy. All services within the system need to conform to this interface.

Constructor Summary

QosServiceImpl(ServiceProperties serviceProperties)

Method Summary

void	closeBrokerConnection()
void	connectionInitialized(boolean registrationSuccessful)
void	deregisterConsumer(int consumerId)
void	deregisterProducer(int producerId) This method is used to register producers with the QoS Manager.
int	generateConstraintId()
int	generateConsumerId()
int	generateProducerId()
int	getEntityId()
NBEventGenerator	getEventGenerator()
FragmentationService	getFragmentationService()
EventConsumerImpl	getRecoveringConsumer(long recoveryId)
EventProducerImpl	getRecoveringProducer(long recoveryId)
ServiceProperties	getServiceProperties()
TDService	getTDService()
boolean	hasPendingTransfers()
void	initializeBrokerCommunications(int entityId, Properties props, String commType)
void	onAdvanceOfSyncpoint(int entityId, int templateId, long advanceSync)
void	onOrderedDelivery(QosEvent qosEvent)
void	onReliableDelivery(QosEvent qosEvent, RdArchivalServiceNotification archNotification)
void	onTimeOrderedDelivery(QosEvent qosEvent)
void	onTimeSpacedDelivery(QosEvent qosEvent)
void	processConnectionLoss()
void	processReceivedEvent(NBEvent nbEvent)
void	publishEvent(NBEvent nbEvent, ProducerConstraints producerConstraints, int producerId)
long	recoverEntity(int conducerId, int entityId, int templateId, boolean isPublisher)
void	registerConsumer(int consumerId, EventConsumer consumer) This method registers a consumer with the Qos manager
void	registerProducer(int producerId, EventProducer producer) This method is used to register producers with the QoS Manager.
void	restartRtspServices()
void	setConnLossListener(ConnectionLossListener connLossListener)
void	startTdsServices()
void	subscribeTo(Profile profile, ConsumerConstraints consumerConstraints, int consumerId)
void	terminateServices()
void	unsubscribe(Profile profile, int consumerId)

Methods inherited from class java.lang.Object

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

Constructor Detail

QosServiceImpl

public QosServiceImpl(ServiceProperties serviceProperties)

Method Detail

startTdsServices

public void startTdsServices()

getServiceProperties

public ServiceProperties getServiceProperties()

restartRtspServices

public void restartRtspServices()

getTDService

public TDService getTDService()

connectionInitialized

public void connectionInitialized(boolean registrationSuccessful)

initializeBrokerCommunications

public void initializeBrokerCommunications(int entityId,
                                           Properties props,
                                           String commType)
                                    throws ServiceException

Throws:

ServiceException

closeBrokerConnection

public void closeBrokerConnection()
                           throws ServiceException

Throws:

ServiceException

hasPendingTransfers

public boolean hasPendingTransfers()

setConnLossListener

public final void setConnLossListener(ConnectionLossListener connLossListener)

processConnectionLoss

public void processConnectionLoss()

terminateServices

public void terminateServices()
                       throws ServiceException

Throws:

ServiceException

getEntityId

public int getEntityId()

getEventGenerator

public NBEventGenerator getEventGenerator()

getFragmentationService

public FragmentationService getFragmentationService()

processReceivedEvent

public void processReceivedEvent(NBEvent nbEvent)

onReliableDelivery

public void onReliableDelivery(QosEvent qosEvent,
                               RdArchivalServiceNotification archNotification)

onAdvanceOfSyncpoint

public void onAdvanceOfSyncpoint(int entityId,
                                 int templateId,
                                 long advanceSync)

onOrderedDelivery

public void onOrderedDelivery(QosEvent qosEvent)

onTimeOrderedDelivery

public void onTimeOrderedDelivery(QosEvent qosEvent)

onTimeSpacedDelivery

public void onTimeSpacedDelivery(QosEvent qosEvent)

generateConsumerId

public int generateConsumerId()

generateProducerId

public int generateProducerId()

generateConstraintId

public int generateConstraintId()

registerConsumer

public void registerConsumer(int consumerId,
                             EventConsumer consumer)

This method registers a consumer with the Qos manager

deregisterConsumer

public void deregisterConsumer(int consumerId)

registerProducer

public void registerProducer(int producerId,
                             EventProducer producer)

This method is used to register producers with the QoS Manager.

deregisterProducer

public void deregisterProducer(int producerId)

This method is used to register producers with the QoS Manager.

publishEvent

public void publishEvent(NBEvent nbEvent,
                         ProducerConstraints producerConstraints,
                         int producerId)
                  throws ServiceException

Throws:

ServiceException

subscribeTo

public void subscribeTo(Profile profile,
                        ConsumerConstraints consumerConstraints,
                        int consumerId)
                 throws ServiceException

Throws:

ServiceException

unsubscribe

public void unsubscribe(Profile profile,
                        int consumerId)
                 throws ServiceException

Throws:

ServiceException

recoverEntity

public long recoverEntity(int conducerId,
                          int entityId,
                          int templateId,
                          boolean isPublisher)
                   throws ServiceException

Throws:

ServiceException

getRecoveringConsumer

public EventConsumerImpl getRecoveringConsumer(long recoveryId)

getRecoveringProducer

public EventProducerImpl getRecoveringProducer(long recoveryId)