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 booleanclosedprotected BooleanSupplierkeepOnSendingprotected AsyncJms2ProducerFacadeproducerprotected booleanstopLoadprotected MicrosTimeProvidertimeProvider
-
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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Future<?>asyncClose(Runnable onClosed)protected voidasyncContinue()protected voidasyncContinue(long usDelay)io.netty.util.concurrent.OrderedEventExecutorgetExecutor()ExceptiongetFatalException()AsyncJms2ProducerFacadegetProducer()org.HdrHistogram.SingleWriterRecordergetSendCompletedLatencies()org.HdrHistogram.SingleWriterRecordergetWaitLatencies()booleanisCompleted()voidonCompletion(javax.jms.Message message)voidonException(javax.jms.Message message, Exception exception)protected booleantrySend(long sendTime)protected booleantrySend(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:
getFatalExceptionin interfaceProducerLoadGenerator
-
getSendCompletedLatencies
public org.HdrHistogram.SingleWriterRecorder getSendCompletedLatencies()
- Specified by:
getSendCompletedLatenciesin interfaceProducerLoadGenerator
-
getWaitLatencies
public org.HdrHistogram.SingleWriterRecorder getWaitLatencies()
- Specified by:
getWaitLatenciesin interfaceProducerLoadGenerator
-
getProducer
public AsyncJms2ProducerFacade getProducer()
- Specified by:
getProducerin interfaceProducerLoadGenerator
-
isCompleted
public boolean isCompleted()
- Specified by:
isCompletedin interfaceProducerLoadGenerator
-
getExecutor
public io.netty.util.concurrent.OrderedEventExecutor getExecutor()
- Specified by:
getExecutorin interfaceProducerLoadGenerator
-
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:
onCompletionin interfacejavax.jms.CompletionListener
-
onException
public void onException(javax.jms.Message message, Exception exception)- Specified by:
onExceptionin interfacejavax.jms.CompletionListener
-
asyncClose
public Future<?> asyncClose(Runnable onClosed)
- Specified by:
asyncClosein interfaceProducerLoadGenerator
-
-