org.jboss.set.aphrodite

Class JsonStreamService

java.lang.Object

org.jboss.set.aphrodite.JsonStreamService

All Implemented Interfaces:

StreamService

public class JsonStreamService
extends Object
implements StreamService

A stream service which reads stream date from the specified JSON file. This implementation assumes that streams are written in order in the json file, i.e. the most recent (upstream) issue is specified as the first JSON object in the "streams" JSON array. An example JSON file can be found at https://github.com/jboss-set/jboss-streams

Author:

Ryan Emerson

Constructor Summary

Constructors

Constructor and Description
JsonStreamService(Aphrodite aphrodite)
JsonStreamService(Aphrodite aphrodite, String jsonFileLocation)

Method Summary

Modifier and Type	Method and Description
Stream	getStream(String streamName) Get a specific Stream object based upon its String name.
List<Stream>	getStreams() Returns all streams discovered by this service.
void	loadStreamData()

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonStreamService

public JsonStreamService(Aphrodite aphrodite)

JsonStreamService

public JsonStreamService(Aphrodite aphrodite,
                         String jsonFileLocation)

Method Detail

getStreams

public List<Stream> getStreams()

Description copied from interface: StreamService

Returns all streams discovered by this service.

Specified by:

getStreams in interface StreamService

Returns:

a list of all streams discovered by this StreamService

getStream

public Stream getStream(String streamName)

Description copied from interface: StreamService

Get a specific Stream object based upon its String name.

Specified by:

getStream in interface StreamService

Parameters:

streamName - the name of the Stream to be returned.

Returns:

Stream the Stream object which corresponds to the specified streamName if it exists, otherwise null.

loadStreamData

public void loadStreamData()
                    throws NotFoundException

Throws:

NotFoundException