org.perfcake.message.generator

Class DefaultMessageGenerator

java.lang.Object

org.perfcake.message.generator.AbstractMessageGenerator

org.perfcake.message.generator.DefaultMessageGenerator

All Implemented Interfaces:

MessageGenerator

Direct Known Subclasses:

ConstantSpeedMessageGenerator, RampUpDownGenerator

public class DefaultMessageGenerator
extends AbstractMessageGenerator

Generates maximal load using a given number of threads.

Author:

Martin Večeřa, Pavel Macík

Constructor Summary

Constructors

Constructor and Description
DefaultMessageGenerator()

Method Summary

Modifier and Type	Method and Description
void	generate() Generates the messages.
long	getDuration() Gets the duration period for which the generator will generate the measured load.
long	getMonitoringPeriod() Gets a monitoring period in which the sender task queue is filled with new tasks.
int	getSenderTaskQueueSize() Gets the size of the internal sender task queue.
long	getShutdownPeriod() Gets the shutdown period.
DefaultMessageGenerator	setMonitoringPeriod(long monitoringPeriod) Gets a monitoring period in which the sender task queue is filled with new tasks.
void	setReportManager(ReportManager reportManager) Sets the ReportManager to be used for the current performance test execution.
DefaultMessageGenerator	setSenderTaskQueueSize(int senderTaskQueueSize) Sets the the size of the internal sender task queue.
DefaultMessageGenerator	setShutdownPeriod(long shutdownPeriod) Sets the shutdown period which tells how frequently we should check for threads finishing their work.

Methods inherited from class org.perfcake.message.generator.AbstractMessageGenerator

close, getActiveThreadsCount, getTasksInQueue, getThreads, init, interrupt, isFailFast, setCorrelator, setRunInfo, setSequenceManager, setThreads, setValidationManager

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultMessageGenerator

public DefaultMessageGenerator()

Method Detail

getShutdownPeriod

public long getShutdownPeriod()

Gets the shutdown period. During a shutdown, the thread queue is regularly checked for the threads finishing their work. If the same amount of threads keeps running for this period, they are forcefully stopped.

Returns:

Current shutdown period in ms.

setShutdownPeriod

public DefaultMessageGenerator setShutdownPeriod(long shutdownPeriod)

Sets the shutdown period which tells how frequently we should check for threads finishing their work. During a shutdown, the thread queue is regularly checked for the threads finishing their work. If the same amount of threads keeps running for this period, they are forcefully stopped.

Parameters:

shutdownPeriod - The new shutdown period.

Returns:

Instance of this to support fluent API.

setReportManager

public void setReportManager(ReportManager reportManager)

Description copied from class: AbstractMessageGenerator

Sets the ReportManager to be used for the current performance test execution.

Specified by:

setReportManager in interface MessageGenerator

Overrides:

setReportManager in class AbstractMessageGenerator

Parameters:

reportManager - ReportManager to be used.

generate

public void generate()
              throws Exception

Description copied from class: AbstractMessageGenerator

Generates the messages. This actually executes the whole performance test.

Specified by:

generate in interface MessageGenerator

Specified by:

generate in class AbstractMessageGenerator

Throws:

Exception - When it was not possible to generate the messages.

getMonitoringPeriod

public long getMonitoringPeriod()

Gets a monitoring period in which the sender task queue is filled with new tasks.

Returns:

The monitoring period in milliseconds.

setMonitoringPeriod

public DefaultMessageGenerator setMonitoringPeriod(long monitoringPeriod)

Gets a monitoring period in which the sender task queue is filled with new tasks.

Parameters:

monitoringPeriod - The monitoring period.

Returns:

Instance of this to support fluent API.

getDuration

public long getDuration()

Gets the duration period for which the generator will generate the measured load.

Returns:

The duration in the units of run type.

getSenderTaskQueueSize

public int getSenderTaskQueueSize()

Gets the size of the internal sender task queue.

Returns:

The sender task queue size.

setSenderTaskQueueSize

public DefaultMessageGenerator setSenderTaskQueueSize(int senderTaskQueueSize)

Sets the the size of the internal sender task queue.

Parameters:

senderTaskQueueSize - The sender task queue size.

Returns:

Instance of this to support fluent API.