Package org.apache.activemq.artemis.cli.commands.messages.perf

Interface ProducerLoadGenerator

All Superinterfaces:

java.lang.Runnable

All Known Implementing Classes:

ProducerMaxLoadGenerator, ProducerTargetRateLoadGenerator, SkeletalProducerLoadGenerator

public interface ProducerLoadGenerator
extends java.lang.Runnable

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.Future<?>	asyncClose(java.lang.Runnable onClosed)
io.netty.util.concurrent.OrderedEventExecutor	getExecutor()
java.lang.Exception	getFatalException()
AsyncJms2ProducerFacade	getProducer()
org.HdrHistogram.SingleWriterRecorder	getSendCompletedLatencies()
org.HdrHistogram.SingleWriterRecorder	getWaitLatencies()
boolean	isCompleted()
void	run()

Method Detail

getExecutor

io.netty.util.concurrent.OrderedEventExecutor getExecutor()

run

void run()

Specified by:

run in interface java.lang.Runnable

asyncClose

java.util.concurrent.Future<?> asyncClose(java.lang.Runnable onClosed)

getWaitLatencies

org.HdrHistogram.SingleWriterRecorder getWaitLatencies()

getSendCompletedLatencies

org.HdrHistogram.SingleWriterRecorder getSendCompletedLatencies()

getProducer

AsyncJms2ProducerFacade getProducer()

isCompleted

boolean isCompleted()

getFatalException

java.lang.Exception getFatalException()