com.rabbitmq.perf

Class ProducerParameters

java.lang.Object

com.rabbitmq.perf.ProducerParameters

public class ProducerParameters
extends java.lang.Object

Since:

2.1.0

Constructor Summary

Constructors

Constructor and Description
ProducerParameters()

Method Summary

Modifier and Type	Method and Description
com.rabbitmq.client.Channel	getChannel()
MulticastSet.CompletionHandler	getCompletionHandler()
long	getConfirm()
int	getConfirmTimeout()
java.lang.String	getExchangeName()
java.util.List<?>	getFlags()
java.lang.String	getId()
MessageBodySource	getMessageBodySource()
java.util.Map<java.lang.String,java.lang.Object>	getMessageProperties()
int	getMsgLimit()
PerformanceMetrics	getPerformanceMetrics()
int	getRandomStartDelayInSeconds()
com.rabbitmq.perf.ValueIndicator<java.lang.Float>	getRateIndicator()
com.rabbitmq.perf.Recovery.RecoveryProcess	getRecoveryProcess()
int	getRoutingKeyCacheSize()
com.rabbitmq.perf.StartListener	getStartListener()
TimestampProvider	getTsp()
int	getTxSize()
boolean	isRandomRoutingKey()
ProducerParameters	setChannel(com.rabbitmq.client.Channel channel)
ProducerParameters	setCompletionHandler(MulticastSet.CompletionHandler completionHandler)
ProducerParameters	setConfirm(long confirm)
ProducerParameters	setConfirmTimeout(int confirmTimeout)
ProducerParameters	setExchangeName(java.lang.String exchangeName)
ProducerParameters	setFlags(java.util.List<?> flags)
ProducerParameters	setId(java.lang.String id)
ProducerParameters	setMessageBodySource(MessageBodySource messageBodySource)
ProducerParameters	setMessageProperties(java.util.Map<java.lang.String,java.lang.Object> messageProperties)
ProducerParameters	setMsgLimit(int msgLimit)
ProducerParameters	setPerformanceMetrics(PerformanceMetrics performanceMetrics)
ProducerParameters	setRandomRoutingKey(boolean randomRoutingKey)
ProducerParameters	setRandomStartDelayInSeconds(int randomStartDelayInSeconds)
ProducerParameters	setRateIndicator(com.rabbitmq.perf.ValueIndicator<java.lang.Float> rateIndicator)
ProducerParameters	setRecoveryProcess(com.rabbitmq.perf.Recovery.RecoveryProcess recoveryProcess)
ProducerParameters	setRoutingKeyCacheSize(int routingKeyCacheSize)
ProducerParameters	setStartListener(com.rabbitmq.perf.StartListener startListener)
ProducerParameters	setTsp(TimestampProvider tsp)
ProducerParameters	setTxSize(int txSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProducerParameters

public ProducerParameters()

Method Detail

getChannel

public com.rabbitmq.client.Channel getChannel()

setChannel

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

getExchangeName

public java.lang.String getExchangeName()

setExchangeName

public ProducerParameters setExchangeName(java.lang.String exchangeName)

getId

public java.lang.String getId()

setId

public ProducerParameters setId(java.lang.String id)

isRandomRoutingKey

public boolean isRandomRoutingKey()

setRandomRoutingKey

public ProducerParameters setRandomRoutingKey(boolean randomRoutingKey)

getFlags

public java.util.List<?> getFlags()

setFlags

public ProducerParameters setFlags(java.util.List<?> flags)

getTxSize

public int getTxSize()

setTxSize

public ProducerParameters setTxSize(int txSize)

getMsgLimit

public int getMsgLimit()

setMsgLimit

public ProducerParameters setMsgLimit(int msgLimit)

getConfirm

public long getConfirm()

setConfirm

public ProducerParameters setConfirm(long confirm)

getConfirmTimeout

public int getConfirmTimeout()

setConfirmTimeout

public ProducerParameters setConfirmTimeout(int confirmTimeout)

getMessageBodySource

public MessageBodySource getMessageBodySource()

setMessageBodySource

public ProducerParameters setMessageBodySource(MessageBodySource messageBodySource)

getTsp

public TimestampProvider getTsp()

setTsp

public ProducerParameters setTsp(TimestampProvider tsp)

getPerformanceMetrics

public PerformanceMetrics getPerformanceMetrics()

setPerformanceMetrics

public ProducerParameters setPerformanceMetrics(PerformanceMetrics performanceMetrics)

getMessageProperties

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

setMessageProperties

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

getCompletionHandler

public MulticastSet.CompletionHandler getCompletionHandler()

setCompletionHandler

public ProducerParameters setCompletionHandler(MulticastSet.CompletionHandler completionHandler)

getRoutingKeyCacheSize

public int getRoutingKeyCacheSize()

setRoutingKeyCacheSize

public ProducerParameters setRoutingKeyCacheSize(int routingKeyCacheSize)

getRandomStartDelayInSeconds

public int getRandomStartDelayInSeconds()

setRandomStartDelayInSeconds

public ProducerParameters setRandomStartDelayInSeconds(int randomStartDelayInSeconds)

getRecoveryProcess

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

setRecoveryProcess

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

getRateIndicator

public com.rabbitmq.perf.ValueIndicator<java.lang.Float> getRateIndicator()

setRateIndicator

public ProducerParameters setRateIndicator(com.rabbitmq.perf.ValueIndicator<java.lang.Float> rateIndicator)

getStartListener

public com.rabbitmq.perf.StartListener getStartListener()

setStartListener

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