public abstract class AbstractAutoSpawnReceiver extends AbstractReceiver implements Runnable
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)
.Constructor and Description |
---|
AbstractAutoSpawnReceiver() |
Modifier and Type | Method and Description |
---|---|
abstract void |
run() |
void |
start()
Starts all receiver threads.
|
void |
stop()
Stops all the receiver threads.
|
getSource, setCorrelator, setSource, setThreads
public void start() throws PerfCakeException
Receiver
start
in interface Receiver
PerfCakeException
- When it was not possible to start all threads.Copyright © 2010–2017 PerfCake Community. All rights reserved.