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

Class SkeletalProducerLoadGenerator

java.lang.Object

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

All Implemented Interfaces:

Runnable, javax.jms.CompletionListener, ProducerLoadGenerator

Direct Known Subclasses:

ProducerMaxLoadGenerator, ProducerTargetRateLoadGenerator

public abstract class SkeletalProducerLoadGenerator
extends Object
implements javax.jms.CompletionListener, ProducerLoadGenerator

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	closed
protected BooleanSupplier	keepOnSending
protected AsyncJms2ProducerFacade	producer
protected boolean	stopLoad
protected MicrosTimeProvider	timeProvider

Constructor Summary

Constructors

Constructor	Description
SkeletalProducerLoadGenerator(AsyncJms2ProducerFacade producer, io.netty.util.concurrent.OrderedEventExecutor executor, MicrosTimeProvider timeProvider, BooleanSupplier keepOnSending, String group, byte[] msgContent, org.HdrHistogram.SingleWriterRecorder sendCompletedLatencies, org.HdrHistogram.SingleWriterRecorder waitLatencies)

Method Summary

Modifier and Type	Method	Description
Future<?>	asyncClose(Runnable onClosed)
protected void	asyncContinue()
protected void	asyncContinue(long usDelay)
io.netty.util.concurrent.OrderedEventExecutor	getExecutor()
Exception	getFatalException()
AsyncJms2ProducerFacade	getProducer()
org.HdrHistogram.SingleWriterRecorder	getSendCompletedLatencies()
org.HdrHistogram.SingleWriterRecorder	getWaitLatencies()
boolean	isCompleted()
void	onCompletion(javax.jms.Message message)
void	onException(javax.jms.Message message, Exception exception)
protected boolean	trySend(long sendTime)
protected boolean	trySend(long expectedSendTime, long sendTime)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.cli.commands.messages.perf.ProducerLoadGenerator

run

Field Detail

producer

protected final AsyncJms2ProducerFacade producer

keepOnSending

protected final BooleanSupplier keepOnSending

timeProvider

protected final MicrosTimeProvider timeProvider

closed

protected boolean closed

stopLoad

protected volatile boolean stopLoad

Constructor Detail

SkeletalProducerLoadGenerator

public SkeletalProducerLoadGenerator(AsyncJms2ProducerFacade producer,
                                     io.netty.util.concurrent.OrderedEventExecutor executor,
                                     MicrosTimeProvider timeProvider,
                                     BooleanSupplier keepOnSending,
                                     String group,
                                     byte[] msgContent,
                                     org.HdrHistogram.SingleWriterRecorder sendCompletedLatencies,
                                     org.HdrHistogram.SingleWriterRecorder waitLatencies)

Method Detail

getFatalException

public Exception getFatalException()

Specified by:

getFatalException in interface ProducerLoadGenerator

getSendCompletedLatencies

public org.HdrHistogram.SingleWriterRecorder getSendCompletedLatencies()

Specified by:

getSendCompletedLatencies in interface ProducerLoadGenerator

getWaitLatencies

public org.HdrHistogram.SingleWriterRecorder getWaitLatencies()

Specified by:

getWaitLatencies in interface ProducerLoadGenerator

getProducer

public AsyncJms2ProducerFacade getProducer()

Specified by:

getProducer in interface ProducerLoadGenerator

isCompleted

public boolean isCompleted()

Specified by:

isCompleted in interface ProducerLoadGenerator

getExecutor

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

Specified by:

getExecutor in interface ProducerLoadGenerator

asyncContinue

protected final void asyncContinue()

asyncContinue

protected final void asyncContinue(long usDelay)

trySend

protected final boolean trySend(long sendTime)

trySend

protected final boolean trySend(long expectedSendTime,
                                long sendTime)

onCompletion

public void onCompletion(javax.jms.Message message)

Specified by:

onCompletion in interface javax.jms.CompletionListener

onException

public void onException(javax.jms.Message message,
                        Exception exception)

Specified by:

onException in interface javax.jms.CompletionListener

asyncClose

public Future<?> asyncClose(Runnable onClosed)

Specified by:

asyncClose in interface ProducerLoadGenerator