cgl.narada.service.qos.impl
Class QosServiceImpl

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


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