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

Class MessageListenerBenchmark

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, BenchmarkService

public final class MessageListenerBenchmark
extends java.lang.Object
implements BenchmarkService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MessageListenerBenchmark.MessageCountLimiter

Constructor Summary

Constructors

Constructor	Description
MessageListenerBenchmark(javax.jms.ConnectionFactory factory, MicrosTimeProvider timeProvider, int consumers, long messageCount, int connections, java.lang.String clientID, javax.jms.Destination[] destinations, boolean transaction, int sharedSubscription, boolean durableSubscription, boolean canDelayMessageCount)

Method Summary

Modifier and Type	Method	Description
boolean	anyError()
void	close()
RecordingMessageListener[]	getListeners()
boolean	isRunning()
void	setMessageCount(long messageCount)
MessageListenerBenchmark	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageListenerBenchmark

public MessageListenerBenchmark(javax.jms.ConnectionFactory factory,
                                MicrosTimeProvider timeProvider,
                                int consumers,
                                long messageCount,
                                int connections,
                                java.lang.String clientID,
                                javax.jms.Destination[] destinations,
                                boolean transaction,
                                int sharedSubscription,
                                boolean durableSubscription,
                                boolean canDelayMessageCount)

Method Detail

getListeners

public RecordingMessageListener[] getListeners()

anyError

public boolean anyError()

Specified by:

anyError in interface BenchmarkService

isRunning

public boolean isRunning()

Specified by:

isRunning in interface BenchmarkService

setMessageCount

public void setMessageCount(long messageCount)

start

public MessageListenerBenchmark start()

Specified by:

start in interface BenchmarkService

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface BenchmarkService