org.maestro.client.exchange

Class MaestroCollectorExecutor

java.lang.Object

org.maestro.client.exchange.AbstractMaestroExecutor

org.maestro.client.exchange.MaestroCollectorExecutor

All Implemented Interfaces:

Runnable

public class MaestroCollectorExecutor
extends AbstractMaestroExecutor

A simplified executor to be used along with a maestro client. It is meant to run in a thread, along side with the sending peer. Received messages can be collected via collect method.

Constructor Summary

Constructors

Constructor and Description
MaestroCollectorExecutor(String url) Constructor

Method Summary

Modifier and Type	Method and Description
void	clear() Collect the messages received in background
MaestroCollector	getCollector()
void	stop() Stops the executor

Methods inherited from class org.maestro.client.exchange.AbstractMaestroExecutor

getMaestroPeer, run, start, start

Methods inherited from class java.lang.Object

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

Constructor Detail

MaestroCollectorExecutor

public MaestroCollectorExecutor(String url)
                         throws MaestroConnectionException

Constructor

Parameters:

url - Maestro broker URL

Throws:

MaestroConnectionException - if unable to connect to the Maestro broker

Method Detail

clear

public void clear()

Collect the messages received in background

stop

public void stop()

Description copied from class: AbstractMaestroExecutor

Stops the executor

Overrides:

stop in class AbstractMaestroExecutor

getCollector

public MaestroCollector getCollector()