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

Constructor and Description
AbstractMaestroExecutor(AbstractMaestroPeer maestroPeer) Constructor

Method Summary

Modifier and Type	Method and Description
protected AbstractMaestroPeer	getMaestroPeer() Get the Maestro peer
void	run() Runs the executor
void	start(String[] topics) 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

public AbstractMaestroExecutor(AbstractMaestroPeer 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 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

run

public final void run()

Runs the executor

Specified by:

run in interface Runnable

stop

public void stop()

Stops the executor