Class MessageListenerBenchmark

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable, BenchmarkService

public final class MessageListenerBenchmark
extends Object
implements BenchmarkService

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	MessageListenerBenchmark.MessageCountLimiter

Constructor Summary

Constructors

Constructor	Description
MessageListenerBenchmark(javax.jms.ConnectionFactory factory, MicrosTimeProvider timeProvider, int consumers, long messageCount, int connections, 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 Object

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

Constructor Details

MessageListenerBenchmark

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

Method Details

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 AutoCloseable

Specified by:

close in interface BenchmarkService