com.rabbitmq.perf

Class MulticastParams

java.lang.Object

com.rabbitmq.perf.MulticastParams

public class MulticastParams
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MulticastParams()

Method Summary

Modifier and Type	Method and Description
java.util.List<com.rabbitmq.perf.MulticastParams.TopologyHandlerResult>	configureAllQueues(java.util.List<com.rabbitmq.client.Connection> connections)
Consumer	createConsumer(com.rabbitmq.client.Connection connection, PerformanceMetrics performanceMetrics, com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator, MulticastSet.CompletionHandler completionHandler, java.util.concurrent.ExecutorService executorService, java.util.concurrent.ScheduledExecutorService topologyRecordingScheduledExecutorService)
Producer	createProducer(com.rabbitmq.client.Connection connection, PerformanceMetrics performanceMetrics, MulticastSet.CompletionHandler completionHandler, com.rabbitmq.perf.ValueIndicator<java.lang.Float> rateIndicator, com.rabbitmq.perf.ValueIndicator<java.lang.Integer> messageSizeIndicator)
void	deleteAutoDeleteQueuesIfNecessary(com.rabbitmq.client.Connection connection)
int	getConsumerChannelCount()
int	getConsumerCount()
java.util.List<java.lang.String>	getConsumerLatencies()
long	getConsumerLatencyInMicroseconds()
int	getConsumerMsgCount()
float	getConsumerRateLimit()
boolean	getConsumerSlowStart()
java.time.Duration	getConsumerStartDelay()
int	getConsumersThreadPools()
int	getConsumerThreadCount()
com.rabbitmq.perf.PerfTest.EXIT_WHEN	getExitWhen()
int	getHeartbeatSenderThreads()
java.util.List<java.lang.String>	getMessageSizes()
int	getMinMsgSize()
int	getProducerChannelCount()
int	getProducerCount()
int	getProducerMsgCount()
int	getProducerRandomStartDelayInSeconds()
float	getProducerRateLimit()
int	getProducerSchedulerThreadCount()
int	getProducerThreadCount()
java.time.Duration	getPublishingInterval()
java.util.List<java.lang.String>	getPublishingRates()
int	getServersStartUpTimeout()
int	getServersUpLimit()
int	getShutdownTimeout()
int	getTimeLimit()
boolean	hasLimit()
void	init()
boolean	isExclusive()
boolean	isPolling()
void	resetTopologyHandler()
void	setAutoAck(boolean autoAck)
void	setAutoDelete(boolean autoDelete)
void	setBodyContentType(java.lang.String bodyContentType)
void	setBodyCount(int bodyCount)
void	setBodyFieldCount(int bodyFieldCount)
void	setBodyFiles(java.util.List<java.lang.String> bodyFiles)
void	setChannelPrefetch(int channelPrefetch)
void	setConfirm(long confirm)
void	setConfirmTimeout(int confirmTimeout)
void	setConsumerArguments(java.util.Map<java.lang.String,java.lang.Object> consumerArguments)
void	setConsumerChannelCount(int consumerChannelCount)
void	setConsumerCount(int consumerCount)
void	setConsumerLatencies(java.util.List<java.lang.String> consumerLatencies)
void	setConsumerLatencyInMicroseconds(long consumerLatencyInMicroseconds)
void	setConsumerMsgCount(int consumerMsgCount)
void	setConsumerPrefetch(int consumerPrefetch)
void	setConsumerRateLimit(float consumerRateLimit)
void	setConsumerSlowStart(boolean slowStart)
void	setConsumersThreadPools(int consumersThreadPools)
void	setConsumerTxSize(int consumerTxSize)
void	setExchangeName(java.lang.String exchangeName)
void	setExchangeType(java.lang.String exchangeType)
void	setExclusive(boolean exclusive)
void	setExitWhen(com.rabbitmq.perf.PerfTest.EXIT_WHEN exitWhen)
void	setFlags(java.util.List<java.lang.String> flags)
void	setHeartbeatSenderThreads(int heartbeatSenderThreads)
void	setJsonBody(boolean jsonBody)
void	setMessageProperties(java.util.Map<java.lang.String,java.lang.Object> messageProperties)
void	setMessageSizes(java.util.List<java.lang.String> messageSizes)
void	setMinMsgSize(int minMsgSize)
void	setMsgCount(int msgCount)
void	setMultiAckEvery(int multiAckEvery)
void	setNack(boolean nack)
void	setPolling(boolean polling)
void	setPollingInterval(int pollingInterval)
void	setPredeclared(boolean predeclared)
void	setProducerChannelCount(int producerChannelCount)
void	setProducerCount(int producerCount)
void	setProducerMsgCount(int producerMsgCount)
void	setProducerRandomStartDelayInSeconds(int producerRandomStartDelayInSeconds)
void	setProducerRateLimit(float producerRateLimit)
void	setProducerSchedulerThreadCount(int producerSchedulerThreadCount)
void	setProducerTxSize(int producerTxSize)
void	setPublishingInterval(java.time.Duration publishingInterval)
void	setPublishingRates(java.util.List<java.lang.String> publishingRates)
void	setQueueArguments(java.util.Map<java.lang.String,java.lang.Object> queueArguments)
void	setQueueNames(java.util.List<java.lang.String> queueNames)
void	setQueuePattern(java.lang.String queuePattern)
void	setQueueSequenceFrom(int queueSequenceFrom)
void	setQueueSequenceTo(int queueSequenceTo)
void	setQueuesInSequence(boolean queuesInSequence)
void	setRandomRoutingKey(boolean randomRoutingKey)
void	setRequeue(boolean requeue)
void	setRoutingKey(java.lang.String routingKey)
void	setRoutingKeyCacheSize(int routingKeyCacheSize)
void	setServersStartUpTimeout(int serversStartUpTimeout)
void	setServersUpLimit(int serversUpLimit)
void	setShutdownTimeout(int shutdownTimeout)
void	setSkipBindingQueues(boolean skipBindingQueues)
void	setStartListener(com.rabbitmq.perf.StartListener startListener)
void	setTimeLimit(int timeLimit)
void	setUseMillis(boolean useMillis)

Methods inherited from class java.lang.Object

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

Constructor Detail

MulticastParams

public MulticastParams()

Method Detail

setExchangeType

public void setExchangeType(java.lang.String exchangeType)

setExchangeName

public void setExchangeName(java.lang.String exchangeName)

setQueueNames

public void setQueueNames(java.util.List<java.lang.String> queueNames)

setRoutingKey

public void setRoutingKey(java.lang.String routingKey)

setRandomRoutingKey

public void setRandomRoutingKey(boolean randomRoutingKey)

setSkipBindingQueues

public void setSkipBindingQueues(boolean skipBindingQueues)

setProducerRateLimit

public void setProducerRateLimit(float producerRateLimit)

setProducerCount

public void setProducerCount(int producerCount)

setProducerChannelCount

public void setProducerChannelCount(int producerChannelCount)

setConsumerRateLimit

public void setConsumerRateLimit(float consumerRateLimit)

setConsumerCount

public void setConsumerCount(int consumerCount)

setConsumerChannelCount

public void setConsumerChannelCount(int consumerChannelCount)

setConsumerSlowStart

public void setConsumerSlowStart(boolean slowStart)

setProducerTxSize

public void setProducerTxSize(int producerTxSize)

setConsumerTxSize

public void setConsumerTxSize(int consumerTxSize)

setConfirm

public void setConfirm(long confirm)

setConfirmTimeout

public void setConfirmTimeout(int confirmTimeout)

setAutoAck

public void setAutoAck(boolean autoAck)

setMultiAckEvery

public void setMultiAckEvery(int multiAckEvery)

setChannelPrefetch

public void setChannelPrefetch(int channelPrefetch)

setConsumerPrefetch

public void setConsumerPrefetch(int consumerPrefetch)

setMinMsgSize

public void setMinMsgSize(int minMsgSize)

setTimeLimit

public void setTimeLimit(int timeLimit)

setUseMillis

public void setUseMillis(boolean useMillis)

setProducerMsgCount

public void setProducerMsgCount(int producerMsgCount)

setConsumerMsgCount

public void setConsumerMsgCount(int consumerMsgCount)

setMsgCount

public void setMsgCount(int msgCount)

setFlags

public void setFlags(java.util.List<java.lang.String> flags)

setAutoDelete

public void setAutoDelete(boolean autoDelete)

setPredeclared

public void setPredeclared(boolean predeclared)

setQueueArguments

public void setQueueArguments(java.util.Map<java.lang.String,java.lang.Object> queueArguments)

setMessageProperties

public void setMessageProperties(java.util.Map<java.lang.String,java.lang.Object> messageProperties)

setConsumersThreadPools

public void setConsumersThreadPools(int consumersThreadPools)

setShutdownTimeout

public void setShutdownTimeout(int shutdownTimeout)

setServersStartUpTimeout

public void setServersStartUpTimeout(int serversStartUpTimeout)

setServersUpLimit

public void setServersUpLimit(int serversUpLimit)

setPublishingRates

public void setPublishingRates(java.util.List<java.lang.String> publishingRates)

setConsumerArguments

public void setConsumerArguments(java.util.Map<java.lang.String,java.lang.Object> consumerArguments)

setExitWhen

public void setExitWhen(com.rabbitmq.perf.PerfTest.EXIT_WHEN exitWhen)

getConsumerCount

public int getConsumerCount()

getConsumerChannelCount

public int getConsumerChannelCount()

getConsumerSlowStart

public boolean getConsumerSlowStart()

getConsumerThreadCount

public int getConsumerThreadCount()

getProducerCount

public int getProducerCount()

getProducerChannelCount

public int getProducerChannelCount()

getProducerThreadCount

public int getProducerThreadCount()

getMinMsgSize

public int getMinMsgSize()

getProducerRateLimit

public float getProducerRateLimit()

setBodyFiles

public void setBodyFiles(java.util.List<java.lang.String> bodyFiles)

setBodyContentType

public void setBodyContentType(java.lang.String bodyContentType)

setQueuePattern

public void setQueuePattern(java.lang.String queuePattern)

setQueueSequenceFrom

public void setQueueSequenceFrom(int queueSequenceFrom)

setQueueSequenceTo

public void setQueueSequenceTo(int queueSequenceTo)

setHeartbeatSenderThreads

public void setHeartbeatSenderThreads(int heartbeatSenderThreads)

setMessageSizes

public void setMessageSizes(java.util.List<java.lang.String> messageSizes)

setConsumerLatencyInMicroseconds

public void setConsumerLatencyInMicroseconds(long consumerLatencyInMicroseconds)

setConsumerLatencies

public void setConsumerLatencies(java.util.List<java.lang.String> consumerLatencies)

getHeartbeatSenderThreads

public int getHeartbeatSenderThreads()

getTimeLimit

public int getTimeLimit()

getConsumerRateLimit

public float getConsumerRateLimit()

getProducerMsgCount

public int getProducerMsgCount()

getConsumerMsgCount

public int getConsumerMsgCount()

setRoutingKeyCacheSize

public void setRoutingKeyCacheSize(int routingKeyCacheSize)

getConsumersThreadPools

public int getConsumersThreadPools()

getShutdownTimeout

public int getShutdownTimeout()

getServersStartUpTimeout

public int getServersStartUpTimeout()

getServersUpLimit

public int getServersUpLimit()

getPublishingRates

public java.util.List<java.lang.String> getPublishingRates()

getMessageSizes

public java.util.List<java.lang.String> getMessageSizes()

getConsumerLatencyInMicroseconds

public long getConsumerLatencyInMicroseconds()

getConsumerLatencies

public java.util.List<java.lang.String> getConsumerLatencies()

getExitWhen

public com.rabbitmq.perf.PerfTest.EXIT_WHEN getExitWhen()

getConsumerStartDelay

public java.time.Duration getConsumerStartDelay()

setPolling

public void setPolling(boolean polling)

isPolling

public boolean isPolling()

setPollingInterval

public void setPollingInterval(int pollingInterval)

setNack

public void setNack(boolean nack)

setRequeue

public void setRequeue(boolean requeue)

setJsonBody

public void setJsonBody(boolean jsonBody)

setBodyFieldCount

public void setBodyFieldCount(int bodyFieldCount)

setBodyCount

public void setBodyCount(int bodyCount)

setQueuesInSequence

public void setQueuesInSequence(boolean queuesInSequence)

setStartListener

public void setStartListener(com.rabbitmq.perf.StartListener startListener)

createProducer

public Producer createProducer(com.rabbitmq.client.Connection connection,
                               PerformanceMetrics performanceMetrics,
                               MulticastSet.CompletionHandler completionHandler,
                               com.rabbitmq.perf.ValueIndicator<java.lang.Float> rateIndicator,
                               com.rabbitmq.perf.ValueIndicator<java.lang.Integer> messageSizeIndicator)
                        throws java.io.IOException

Throws:

java.io.IOException

createConsumer

public Consumer createConsumer(com.rabbitmq.client.Connection connection,
                               PerformanceMetrics performanceMetrics,
                               com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator,
                               MulticastSet.CompletionHandler completionHandler,
                               java.util.concurrent.ExecutorService executorService,
                               java.util.concurrent.ScheduledExecutorService topologyRecordingScheduledExecutorService)
                        throws java.io.IOException

Throws:

java.io.IOException

configureAllQueues

public java.util.List<com.rabbitmq.perf.MulticastParams.TopologyHandlerResult> configureAllQueues(java.util.List<com.rabbitmq.client.Connection> connections)
                                                                                           throws java.io.IOException

Throws:

java.io.IOException

init

public void init()

resetTopologyHandler

public void resetTopologyHandler()

deleteAutoDeleteQueuesIfNecessary

public void deleteAutoDeleteQueuesIfNecessary(com.rabbitmq.client.Connection connection)
                                       throws java.io.IOException,
                                              java.util.concurrent.TimeoutException

Throws:

java.io.IOException

java.util.concurrent.TimeoutException

hasLimit

public boolean hasLimit()

setExclusive

public void setExclusive(boolean exclusive)

isExclusive

public boolean isExclusive()

setPublishingInterval

public void setPublishingInterval(java.time.Duration publishingInterval)

getPublishingInterval

public java.time.Duration getPublishingInterval()

setProducerRandomStartDelayInSeconds

public void setProducerRandomStartDelayInSeconds(int producerRandomStartDelayInSeconds)

getProducerRandomStartDelayInSeconds

public int getProducerRandomStartDelayInSeconds()

getProducerSchedulerThreadCount

public int getProducerSchedulerThreadCount()

setProducerSchedulerThreadCount

public void setProducerSchedulerThreadCount(int producerSchedulerThreadCount)