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

Class ProducerBenchmark

java.lang.Object

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

All Implemented Interfaces:

java.lang.AutoCloseable, BenchmarkService

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

Constructor Summary

Constructors

Constructor

Description

ProducerBenchmark(javax.jms.ConnectionFactory factory, MicrosTimeProvider timeProvider, io.netty.channel.EventLoopGroup loopGroup, int producers, long messageCount, boolean sharedConnections, java.lang.String group, long ttl, int messageSize, javax.jms.Destination[] destinations, boolean persistent, long maxPending, long transactionCapacity, java.lang.Long messageRate, boolean enableMessageID, boolean enableTimestamp)

Method Summary

Modifier and Type	Method	Description
boolean	anyError()
java.util.concurrent.CompletionStage<?>	asyncClose()	After this, now new messages are sent, but there still be some to be completed: the return value can be used to await completions to arrive.
void	close()
long	expectedTotalMessageCountToReceive(int sharedSubscriptions, int consumersPerDestination)
static long	expectedTotalMessageCountToReceive(java.util.stream.Stream<org.apache.activemq.artemis.api.core.ObjLongPair<javax.jms.Destination>> messageSentPerDestination, int sharedSubscriptions, int consumersPerDestination)
ProducerLoadGenerator[]	getGenerators()
boolean	isRunning()
ProducerBenchmark	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerBenchmark

public ProducerBenchmark(javax.jms.ConnectionFactory factory,
                         MicrosTimeProvider timeProvider,
                         io.netty.channel.EventLoopGroup loopGroup,
                         int producers,
                         long messageCount,
                         boolean sharedConnections,
                         java.lang.String group,
                         long ttl,
                         int messageSize,
                         javax.jms.Destination[] destinations,
                         boolean persistent,
                         long maxPending,
                         long transactionCapacity,
                         java.lang.Long messageRate,
                         boolean enableMessageID,
                         boolean enableTimestamp)

Method Detail

expectedTotalMessageCountToReceive

public long expectedTotalMessageCountToReceive(int sharedSubscriptions,
                                               int consumersPerDestination)

expectedTotalMessageCountToReceive

public static long expectedTotalMessageCountToReceive(java.util.stream.Stream<org.apache.activemq.artemis.api.core.ObjLongPair<javax.jms.Destination>> messageSentPerDestination,
                                                      int sharedSubscriptions,
                                                      int consumersPerDestination)

getGenerators

public ProducerLoadGenerator[] getGenerators()

anyError

public boolean anyError()

Specified by:

anyError in interface BenchmarkService

isRunning

public boolean isRunning()

Specified by:

isRunning in interface BenchmarkService

start

public ProducerBenchmark start()

Specified by:

start in interface BenchmarkService

asyncClose

public java.util.concurrent.CompletionStage<?> asyncClose()

After this, now new messages are sent, but there still be some to be completed: the return value can be used to await completions to arrive.

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface BenchmarkService