org.jboss.set.aphrodite.stream.services.json

Class JsonStreamService

java.lang.Object

org.jboss.set.aphrodite.stream.services.json.JsonStreamService

All Implemented Interfaces:

StreamService

public class JsonStreamService
extends Object
implements StreamService

A stream service which reads stream data 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()

Method Summary

Modifier and Type	Method and Description
StreamComponent	getComponentBy(Repository repository, Codebase codebase) Get the StreamComponent which specifies the given repository and codebase.
List<Repository>	getDistinctURLRepositories() Retrieve all Repositories across all Streams.
List<Repository>	getDistinctURLRepositoriesByStream(String streamName) Retrieve the URLs of all Repositories associated with a given Stream.
Stream	getStream(String streamName) Get a specific Stream object based upon its String name.
List<Stream>	getStreams() Returns all streams discovered by this service.
List<Stream>	getStreamsBy(Repository repository, Codebase codebase) Find all the streams associated to the given repository and codebase
boolean	init(Aphrodite aphrodite, AphroditeConfig config) Initialize the stream service.

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonStreamService

public JsonStreamService()

Method Detail

init

public boolean init(Aphrodite aphrodite,
                    AphroditeConfig config)
             throws NotFoundException

Description copied from interface: StreamService

Initialize the stream service.

Specified by:

init in interface StreamService

Throws:

NotFoundException

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, or an empty list if no streams exist.

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.

getDistinctURLRepositories

public List<Repository> getDistinctURLRepositories()

Description copied from interface: StreamService

Retrieve all Repositories across all Streams. Note, that only Repository objects with distinct URLs are returned. This method should never return the same repository twice.

Specified by:

getDistinctURLRepositories in interface StreamService

Returns:

a list of unique Repositories.

getDistinctURLRepositoriesByStream

public List<Repository> getDistinctURLRepositoriesByStream(String streamName)

Description copied from interface: StreamService

Retrieve the URLs of all Repositories associated with a given Stream. Note, that only Repository objects with distinct URLs are returned. This method should never return the same repository twice.

Specified by:

getDistinctURLRepositoriesByStream in interface StreamService

Parameters:

streamName - the name of the Stream containing the returned repositories.

Returns:

a list of unique Repositories.

getStreamsBy

public List<Stream> getStreamsBy(Repository repository,
                                 Codebase codebase)

Description copied from interface: StreamService

Find all the streams associated to the given repository and codebase

Specified by:

getStreamsBy in interface StreamService

Parameters:

repository - the Repository to search against.

codebase - the Codebase to search against.

Returns:

a list of named Stream objects.

getComponentBy

public StreamComponent getComponentBy(Repository repository,
                                      Codebase codebase)

Description copied from interface: StreamService

Get the StreamComponent which specifies the given repository and codebase. Note, this returns the first matching component in the Stream data.

Specified by:

getComponentBy in interface StreamService

Parameters:

repository - the Repository to be searched against.

codebase - the codebase to be searched against.

Returns:

the StreamComponent associated with the given repository and codebase, or null if a StreamComponent does not exist