org.perfcake.message.generator

Class SenderTask

java.lang.Object

org.perfcake.message.generator.SenderTask

All Implemented Interfaces:

Runnable

public class SenderTask
extends Object
implements Runnable

Executes a single task of sending messages from the message store using instances of MessageSender provided by message sender manager (see MessageSenderManager), receiving the message sender's response and handling the reporting and response message validation. Sender task is not part of the public API, it is used from generators.

Author:

Pavel Macík, Martin Večeřa

See Also:

MessageSenderManager

Method Summary

Modifier and Type	Method and Description
void	registerResponse(Serializable response) Notifies the sender task of receiving a response from a separate message channel.
void	run() Executes the scheduled sender task.
void	setCorrelator(Correlator correlator) Sets the correlator that is used to notify us about receiving a response from a separate message channel.
void	setSequenceManager(SequenceManager sequenceManager) Configures a SequenceManager for the sender task.

Methods inherited from class java.lang.Object

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

Method Detail

run

public void run()

Executes the scheduled sender task. This is supposed to be controlled by an enclosing thread.

Specified by:

run in interface Runnable

registerResponse

public void registerResponse(Serializable response)

Notifies the sender task of receiving a response from a separate message channel. This is called from Correlator when Receiver is used.

Parameters:

response - The response corresponding to the original request.

setSequenceManager

public void setSequenceManager(SequenceManager sequenceManager)

Configures a SequenceManager for the sender task.

Parameters:

sequenceManager - SequenceManager to be used by the sender task.

setCorrelator

public void setCorrelator(Correlator correlator)

Sets the correlator that is used to notify us about receiving a response from a separate message channel.

Parameters:

correlator - The correlator to be used.