cgl.narada.service.qos
Interface QosService

All Superinterfaces:

Service

public interface QosService
extends Service

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.

Method Summary

void	closeBrokerConnection()
void	connectionInitialized()
void	deregisterConsumer(int consumerId) Deregister a consumer
void	deregisterProducer(int producerId) This method is used to register producers with the QoS Manager.
int	generateConsumerId() Generates a unique consumer id
int	generateProducerId() Generates a unique producer id
int	getEntityId() Retrieves the entityId of the managed entity
NBEventGenerator	getEventGenerator()
TDService	getTDService() Retrieve the TDS service.
void	initializeBrokerCommunications(int entityId, Properties props, String commType) Initializes broker communications based on the properties specified
void	onAdvanceOfSyncpoint(int entityId, int templateId, long advanceSync) Called upon the advance of the syncpoint associated with an entity
void	onOrderedDelivery(QosEvent qosEvent) Call upon the ordered delivery of an event
void	onReliableDelivery(QosEvent qosEvent, RdArchivalServiceNotification archNotification) Called upon the reliable delivery of an event
void	processReceivedEvent(NBEvent nbEvent) Processes a received event
void	publishEvent(NBEvent nbEvent, ProducerConstraints producerConstraints, int producerId) Publish an event for a producer based on the specified constraints
long	recoverEntity(int conducerId, int entityId, int templateId, boolean isPublisher) Recover
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() Restart Buffering and TDS services.
void	subscribeTo(Profile profile, ConsumerConstraints consumerConstraints, int consumerId) Subscribe to a profile based on the specified consumer constraints
void	terminateServices() Terminate services that are currently running within the JVM
void	unsubscribe(Profile profile) Unsubscribe from a profile

Methods inherited from interface cgl.narada.service.Service

deregisterServiceExceptionListener, deregisterServiceNotificationListener, getEventTypesHandled, getServiceDescription, getServicesPerformed, handleEvent, isStarted, isStopped, loadService, performService, registerServiceExceptionListener, registerServiceNotificationListener, servicePerformed, startService, stopService

Method Detail

getTDService

TDService getTDService()

Retrieve the TDS service.

restartRtspServices

void restartRtspServices()

Restart Buffering and TDS services.

connectionInitialized

void connectionInitialized()

initializeBrokerCommunications

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

Initializes broker communications based on the properties specified

Throws:

ServiceException

getEntityId

int getEntityId()

Retrieves the entityId of the managed entity

getEventGenerator

NBEventGenerator getEventGenerator()

processReceivedEvent

void processReceivedEvent(NBEvent nbEvent)

Processes a received event

onReliableDelivery

void onReliableDelivery(QosEvent qosEvent,
                        RdArchivalServiceNotification archNotification)

Called upon the reliable delivery of an event

onAdvanceOfSyncpoint

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

Called upon the advance of the syncpoint associated with an entity

onOrderedDelivery

void onOrderedDelivery(QosEvent qosEvent)

Call upon the ordered delivery of an event

generateConsumerId

int generateConsumerId()

Generates a unique consumer id

generateProducerId

int generateProducerId()

Generates a unique producer id

registerConsumer

void registerConsumer(int consumerId,
                      EventConsumer consumer)

This method registers a consumer with the Qos manager

deregisterConsumer

void deregisterConsumer(int consumerId)

Deregister a consumer

registerProducer

void registerProducer(int producerId,
                      EventProducer producer)

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

deregisterProducer

void deregisterProducer(int producerId)

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

publishEvent

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

Publish an event for a producer based on the specified constraints

Throws:

ServiceException

subscribeTo

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

Subscribe to a profile based on the specified consumer constraints

Throws:

ServiceException

unsubscribe

void unsubscribe(Profile profile)
                 throws ServiceException

Unsubscribe from a profile

Throws:

ServiceException

recoverEntity

long recoverEntity(int conducerId,
                   int entityId,
                   int templateId,
                   boolean isPublisher)

Recover

closeBrokerConnection

void closeBrokerConnection()
                           throws ServiceException

Throws:

ServiceException

terminateServices

void terminateServices()
                       throws ServiceException

Terminate services that are currently running within the JVM

Throws:

ServiceException