org.perfcake.message.receiver

Class AbstractAutoSpawnReceiver

java.lang.Object

org.perfcake.message.receiver.AbstractReceiver

org.perfcake.message.receiver.AbstractAutoSpawnReceiver

All Implemented Interfaces:

Runnable, Receiver

public abstract class AbstractAutoSpawnReceiver
extends AbstractReceiver
implements Runnable

Simplifies writing of the receivers. An implementation just needs to override its Thread.run() method. The needed number of threads is started and terminated automatically. It is just necessary to pass the received messages to the correlator using Correlator.registerResponse(Serializable, io.vertx.core.MultiMap).

Author:

Martin Večeřa

Constructor Summary

Constructors

Constructor and Description
AbstractAutoSpawnReceiver()

Method Summary

Modifier and Type	Method and Description
abstract void	run()
void	start() Starts all receiver threads.
void	stop() Stops all the receiver threads.

Methods inherited from class org.perfcake.message.receiver.AbstractReceiver

getSource, setCorrelator, setSource, setThreads

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractAutoSpawnReceiver

public AbstractAutoSpawnReceiver()

Method Detail

run

public abstract void run()

Specified by:

run in interface Runnable

start

public void start()
           throws PerfCakeException

Description copied from interface: Receiver

Starts all receiver threads.

Specified by:

start in interface Receiver

Throws:

PerfCakeException - When it was not possible to start all threads.

stop

public void stop()

Description copied from interface: Receiver

Stops all the receiver threads.

Specified by:

stop in interface Receiver