ds.granules.scheduler

Class StreamingService

java.lang.Object

ds.granules.scheduler.StreamingService

public class StreamingService
extends Object

A streaming service class which abstracts minimal operations needed for communications.

Author:

Shrideep Pallickara

Method Summary

Methods

Modifier and Type	Method and Description
cgl.narada.service.client.EventConsumer	createConsumer(cgl.narada.service.client.NBEventListener listener) Create an event consumer
cgl.narada.service.client.EventProducer	createProducer() Create a stream producer
cgl.narada.matching.Profile	createProfile(String streamSynopsis, int synopsisType) Create a profile based on the synopsisTypeString and the synopsis
static StreamingService	getInstance() Get an instance of the StreamingService
void	initialize(String configurationFile, int entityId, Properties props, String commType) Initialize the streaming service based on the specified parameters
boolean	isInitialized() Checks to see if the streaming service has been initialized.
static void	main(String[] args)
void	writeToStream(String streamSynopsis, byte[] payload) Writes a byte[] payload onto the specified stream
void	writeToStream(String streamSynopsis, int synopsisType, byte[] payload) Writes a byte[] payload onto the specified stream

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static StreamingService getInstance()

Get an instance of the StreamingService

Returns:

The singleton instance of the StreamingService

initialize

public void initialize(String configurationFile,
              int entityId,
              Properties props,
              String commType)
                throws CommunicationsException

Initialize the streaming service based on the specified parameters

Parameters:

configurationFile - Used to specify configuration of various services

entityId - The identifier associated with this entity/resource

props - Properties for initializing communications with the broker

commType - The communication type to be used

Throws:

CommunicationsException - If there are communication problems when performing the operation.

isInitialized

public boolean isInitialized()

Checks to see if the streaming service has been initialized.

Returns:

true if it is, and true otherwise.

createProducer

public cgl.narada.service.client.EventProducer createProducer()
                                                       throws CommunicationsException

Create a stream producer

Returns:

The stream producer

Throws:

CommunicationsException - If there are communication problems when performing the operation.

createConsumer

public cgl.narada.service.client.EventConsumer createConsumer(cgl.narada.service.client.NBEventListener listener)
                                                       throws CommunicationsException

Create an event consumer

Parameters:

listener - The listener who would be notified when streams are available

Returns:

An event consumer

Throws:

CommunicationsException - If there are communication problems when performing the operation.

createProfile

public cgl.narada.matching.Profile createProfile(String streamSynopsis,
                                        int synopsisType)
                                          throws CommunicationsException

Create a profile based on the synopsisTypeString and the synopsis

Parameters:

streamSynopsis - The synopsis of the Stream

synopsisType - The synopsis type of the stream in question

Returns:

A profile based on the specified parameters

Throws:

CommunicationsException - If there are communication problems when performing the operation.

writeToStream

public void writeToStream(String streamSynopsis,
                 byte[] payload)
                   throws CommunicationsException

Writes a byte[] payload onto the specified stream

Parameters:

streamSynopsis - The synopsis of the Stream

payload - The payload for the stream fragment

Throws:

CommunicationsException - If there are communication problems when performing the operation.

writeToStream

public void writeToStream(String streamSynopsis,
                 int synopsisType,
                 byte[] payload)
                   throws CommunicationsException

Writes a byte[] payload onto the specified stream

Parameters:

streamSynopsis - The synopsis of the Stream

synopsisType - The synopsis type of the stream in question

payload - The payload for the stream fragment

Throws:

CommunicationsException - If there are communication problems when performing the operation.

main

public static void main(String[] args)

Parameters:

args -