org.maestro.worker.jms

Class JMSReceiverWorker

java.lang.Object

org.maestro.worker.jms.JMSReceiverWorker

All Implemented Interfaces:

Runnable, TestDuration.TestProgress, MaestroReceiverWorker, MaestroWorker

public class JMSReceiverWorker
extends Object
implements MaestroReceiverWorker

A sender worker for JMS-based testing

Constructor Summary

Constructors

Constructor and Description
JMSReceiverWorker()

Method Summary

Modifier and Type	Method and Description
void	fail(Exception exception) Stops the test execution with a failure condition (ie.: to fail due to external causes)
WorkerStateInfo	getWorkerState() Gets the current state of the worker
void	halt() Halt the daemons
boolean	isRunning() Checks whether the worker is in running state.
long	messageCount() It represents the works done expressed in messages processed.
void	run()
void	setWorkerNumber(int number) When multiple workers are involved, set the number of the worker
void	setWorkerOptions(WorkerOptions workerOptions) Sets the options for this worker
void	start() Starts the test
long	startedEpochMillis() It represent the start of the test in milliseconds using Unix Epoch in milliseconds.
void	stop() Stops the test execution
org.HdrHistogram.Histogram	takeLatenciesSnapshot(org.HdrHistogram.Histogram intervalHistogram) It is able to take a snapshot of the current recorder latencies.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.maestro.common.duration.TestDuration.TestProgress

elapsedTime

Constructor Detail

JMSReceiverWorker

public JMSReceiverWorker()

Method Detail

messageCount

public long messageCount()

Description copied from interface: TestDuration.TestProgress

It represents the works done expressed in messages processed.

Specified by:

messageCount in interface TestDuration.TestProgress

Returns:

the number of messages processed

getWorkerState

public WorkerStateInfo getWorkerState()

Description copied from interface: MaestroWorker

Gets the current state of the worker

Specified by:

getWorkerState in interface MaestroWorker

Returns:

the current state of the worker

startedEpochMillis

public long startedEpochMillis()

Description copied from interface: TestDuration.TestProgress

It represent the start of the test in milliseconds using Unix Epoch in milliseconds.

If the test isn't started yet it is an arbitrary negative value.

Specified by:

startedEpochMillis in interface TestDuration.TestProgress

Returns:

the started time in milliseconds from epoch

setWorkerNumber

public void setWorkerNumber(int number)

Description copied from interface: MaestroWorker

When multiple workers are involved, set the number of the worker

Specified by:

setWorkerNumber in interface MaestroWorker

Parameters:

number - the number of this worker

setWorkerOptions

public void setWorkerOptions(WorkerOptions workerOptions)

Description copied from interface: MaestroWorker

Sets the options for this worker

Specified by:

setWorkerOptions in interface MaestroWorker

Parameters:

workerOptions - the worker options to set

start

public void start()

Description copied from interface: MaestroWorker

Starts the test

Specified by:

start in interface MaestroWorker

takeLatenciesSnapshot

public org.HdrHistogram.Histogram takeLatenciesSnapshot(org.HdrHistogram.Histogram intervalHistogram)

Description copied from interface: MaestroWorker

It is able to take a snapshot of the current recorder latencies.

Specified by:

takeLatenciesSnapshot in interface MaestroWorker

Parameters:

intervalHistogram - the new histogram to be used to record latencies from now on

Returns:

the old latencies histogram or null if none has been recorded.

isRunning

public boolean isRunning()

Description copied from interface: MaestroWorker

Checks whether the worker is in running state.

Specified by:

isRunning in interface MaestroWorker

Returns:

true if it is in running state or false otherwise

stop

public void stop()

Description copied from interface: MaestroWorker

Stops the test execution

Specified by:

stop in interface MaestroWorker

fail

public void fail(Exception exception)

Description copied from interface: MaestroWorker

Stops the test execution with a failure condition (ie.: to fail due to external causes)

Specified by:

fail in interface MaestroWorker

halt

public void halt()

Description copied from interface: MaestroWorker

Halt the daemons

Specified by:

halt in interface MaestroWorker

run

public void run()

Specified by:

run in interface Runnable