com.rabbitmq.perf

Class ConsumerParameters

java.lang.Object

com.rabbitmq.perf.ConsumerParameters

public class ConsumerParameters
extends java.lang.Object

Since:

2.8.0

Constructor Summary

Constructors

Constructor and Description
ConsumerParameters()

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getChannel()
MulticastSet.CompletionHandler	getCompletionHandler()
java.util.Map<java.lang.String,java.lang.Object>	getConsumerArguments()
com.rabbitmq.perf.ValueIndicator<java.lang.Long>	getConsumerLatenciesIndicator()
java.util.concurrent.ExecutorService	getExecutorService()
com.rabbitmq.perf.PerfTest.EXIT_WHEN	getExitWhen()
java.lang.String	getId()
int	getMsgLimit()
int	getMultiAckEvery()
PerformanceMetrics	getPerformanceMetrics()
int	getPollingInterval()
java.util.List<java.lang.String>	getQueueNames()
float	getRateLimit()
com.rabbitmq.perf.Recovery.RecoveryProcess	getRecoveryProcess()
com.rabbitmq.perf.StartListener	getStartListener()
TimestampProvider	getTimestampProvider()
java.util.concurrent.ScheduledExecutorService	getTopologyRecoveryScheduledExecutorService()
int	getTxSize()
boolean	isAutoAck()
boolean	isNack()
boolean	isPolling()
boolean	isRequeue()
ConsumerParameters	setAutoAck(boolean autoAck)
ConsumerParameters	setChannel(com.rabbitmq.client.Channel channel)
ConsumerParameters	setCompletionHandler(MulticastSet.CompletionHandler completionHandler)
ConsumerParameters	setConsumerArguments(java.util.Map<java.lang.String,java.lang.Object> consumerArguments)
ConsumerParameters	setConsumerLatencyIndicator(com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator)
ConsumerParameters	setExecutorService(java.util.concurrent.ExecutorService executorService)
ConsumerParameters	setExitWhen(com.rabbitmq.perf.PerfTest.EXIT_WHEN exitWhen)
ConsumerParameters	setId(java.lang.String id)
ConsumerParameters	setMsgLimit(int msgLimit)
ConsumerParameters	setMultiAckEvery(int multiAckEvery)
ConsumerParameters	setNack(boolean nack)
ConsumerParameters	setPerformanceMetrics(PerformanceMetrics performanceMetrics)
ConsumerParameters	setPolling(boolean polling)
ConsumerParameters	setPollingInterval(int pollingInterval)
ConsumerParameters	setQueueNames(java.util.List<java.lang.String> queueNames)
ConsumerParameters	setRateLimit(float rateLimit)
ConsumerParameters	setRecoveryProcess(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess)
ConsumerParameters	setRequeue(boolean requeue)
ConsumerParameters	setStartListener(com.rabbitmq.perf.StartListener startListener)
ConsumerParameters	setTimestampProvider(TimestampProvider timestampProvider)
ConsumerParameters	setTxSize(int txSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerParameters

public ConsumerParameters()

Method Detail

getChannel

public com.rabbitmq.client.Channel getChannel()

setChannel

public ConsumerParameters setChannel(com.rabbitmq.client.Channel channel)

getId

public java.lang.String getId()

setId

public ConsumerParameters setId(java.lang.String id)

getQueueNames

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

setQueueNames

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

getTxSize

public int getTxSize()

setTxSize

public ConsumerParameters setTxSize(int txSize)

isAutoAck

public boolean isAutoAck()

setAutoAck

public ConsumerParameters setAutoAck(boolean autoAck)

getMultiAckEvery

public int getMultiAckEvery()

setMultiAckEvery

public ConsumerParameters setMultiAckEvery(int multiAckEvery)

getPerformanceMetrics

public PerformanceMetrics getPerformanceMetrics()

setPerformanceMetrics

public ConsumerParameters setPerformanceMetrics(PerformanceMetrics performanceMetrics)

getRateLimit

public float getRateLimit()

setRateLimit

public ConsumerParameters setRateLimit(float rateLimit)

getMsgLimit

public int getMsgLimit()

setMsgLimit

public ConsumerParameters setMsgLimit(int msgLimit)

getConsumerLatenciesIndicator

public com.rabbitmq.perf.ValueIndicator<java.lang.Long> getConsumerLatenciesIndicator()

setConsumerLatencyIndicator

public ConsumerParameters setConsumerLatencyIndicator(com.rabbitmq.perf.ValueIndicator<java.lang.Long> consumerLatenciesIndicator)

getTimestampProvider

public TimestampProvider getTimestampProvider()

setTimestampProvider

public ConsumerParameters setTimestampProvider(TimestampProvider timestampProvider)

getCompletionHandler

public MulticastSet.CompletionHandler getCompletionHandler()

setCompletionHandler

public ConsumerParameters setCompletionHandler(MulticastSet.CompletionHandler completionHandler)

getRecoveryProcess

public com.rabbitmq.perf.Recovery.RecoveryProcess getRecoveryProcess()

setRecoveryProcess

public ConsumerParameters setRecoveryProcess(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess)

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

setExecutorService

public ConsumerParameters setExecutorService(java.util.concurrent.ExecutorService executorService)

isPolling

public boolean isPolling()

setPolling

public ConsumerParameters setPolling(boolean polling)

getPollingInterval

public int getPollingInterval()

setPollingInterval

public ConsumerParameters setPollingInterval(int pollingInterval)

isNack

public boolean isNack()

setNack

public ConsumerParameters setNack(boolean nack)

isRequeue

public boolean isRequeue()

setRequeue

public ConsumerParameters setRequeue(boolean requeue)

setConsumerArguments

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

getConsumerArguments

public java.util.Map<java.lang.String,java.lang.Object> getConsumerArguments()

setExitWhen

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

getExitWhen

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

getTopologyRecoveryScheduledExecutorService

public java.util.concurrent.ScheduledExecutorService getTopologyRecoveryScheduledExecutorService()

getStartListener

public com.rabbitmq.perf.StartListener getStartListener()

setStartListener

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