org.maestro.client.exchange

Class AbstractMaestroExecutor

java.lang.Object

org.maestro.client.exchange.AbstractMaestroExecutor

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

MaestroCollectorExecutor, MaestroWorkerExecutor

public class AbstractMaestroExecutor
extends Object
implements Runnable

Provides an abstract interface that can be used to receive data from a Maestro broker.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMaestroExecutor(AbstractMaestroPeer<? extends MaestroNote> maestroPeer) Constructor

Method Summary

Modifier and Type	Method and Description
protected AbstractMaestroPeer<? extends MaestroNote>	getMaestroPeer() Get the Maestro peer
void	run() Runs the executor
void	start(String[] topics) Start running the executor
void	start(String[] topics, int connectionRetries, long retryDelay) Start running the executor
void	stop() Stops the executor

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMaestroExecutor

protected AbstractMaestroExecutor(AbstractMaestroPeer<? extends MaestroNote> maestroPeer)
                           throws MaestroConnectionException

Constructor

Parameters:

maestroPeer - a Maestro peer object is capable of exchange maestro data.

Throws:

MaestroConnectionException - if unable to connect or subscribe

Method Detail

getMaestroPeer

protected AbstractMaestroPeer<? extends MaestroNote> getMaestroPeer()

Get the Maestro peer

Returns:

the maestro peer object

start

public void start(String[] topics)
           throws MaestroConnectionException

Start running the executor

Parameters:

topics - the list of topics associated with this executor

Throws:

MaestroConnectionException - if unable to connect to the broker and subscribe to the topics

start

public void start(String[] topics,
                  int connectionRetries,
                  long retryDelay)
           throws MaestroConnectionException

Start running the executor

Parameters:

topics - the list of topics associated with this executor

Throws:

MaestroConnectionException - if unable to connect to the broker and subscribe to the topics

run

public final void run()

Runs the executor

Specified by:

run in interface Runnable

stop

public void stop()

Stops the executor