org.springframework.cloud.stream.binder.rabbit.properties

Class RabbitProducerProperties

java.lang.Object

org.springframework.cloud.stream.binder.rabbit.properties.RabbitCommonProperties

org.springframework.cloud.stream.binder.rabbit.properties.RabbitProducerProperties

public class RabbitProducerProperties
extends RabbitCommonProperties

Author:

Marius Bogoevici, Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.rabbit.properties.RabbitCommonProperties

RabbitCommonProperties.QuorumConfig

Field Summary

Fields inherited from class org.springframework.cloud.stream.binder.rabbit.properties.RabbitCommonProperties

DEAD_LETTER_EXCHANGE

Constructor Summary

Constructors

Constructor and Description
RabbitProducerProperties()

Method Summary

Modifier and Type	Method and Description
@Min(value=1L,message="Batch Buffer Limit should be greater than zero.") int	getBatchBufferLimit()
String	getBatchingStrategyBeanName()
@Min(value=1L,message="Batch Size should be greater than zero.") int	getBatchSize()
@Min(value=1L,message="Batch Timeout should be greater than zero.") int	getBatchTimeout()
String	getConfirmAckChannel()
org.springframework.expression.Expression	getDelayExpression()
org.springframework.amqp.core.MessageDeliveryMode	getDeliveryMode()
String[]	getHeaderPatterns()
String[]	getRequestHeaderPatterns() Deprecated. - use getHeaderPatterns().
org.springframework.expression.Expression	getRoutingKeyExpression()
boolean	isBatchingEnabled()
boolean	isCompress()
boolean	isTransacted()
void	setBatchBufferLimit(int batchBufferLimit)
void	setBatchingEnabled(boolean batchingEnabled)
void	setBatchingStrategyBeanName(String batchingStrategyBeanName)
void	setBatchSize(int batchSize)
void	setBatchTimeout(int batchTimeout)
void	setCompress(boolean compress)
void	setConfirmAckChannel(String confirmAckChannel)
void	setDelayExpression(org.springframework.expression.Expression delayExpression)
void	setDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode deliveryMode)
void	setHeaderPatterns(String[] replyHeaderPatterns)
void	setRequestHeaderPatterns(String[] requestHeaderPatterns) Deprecated. - use setHeaderPatterns(String[]).
void	setRoutingKeyExpression(org.springframework.expression.Expression routingKeyExpression)
void	setTransacted(boolean transacted)

Methods inherited from class org.springframework.cloud.stream.binder.rabbit.properties.RabbitCommonProperties

getBindingRoutingKey, getBindingRoutingKeyDelimiter, getDeadLetterExchange, getDeadLetterExchangeType, getDeadLetterQueueName, getDeadLetterRoutingKey, getDlqBindingArguments, getDlqDeadLetterExchange, getDlqDeadLetterRoutingKey, getDlqExpires, getDlqMaxLength, getDlqMaxLengthBytes, getDlqMaxPriority, getDlqOverflowBehavior, getDlqQuorum, getDlqTtl, getExchangeType, getExpires, getMaxLength, getMaxLengthBytes, getMaxPriority, getOverflowBehavior, getPrefix, getQueueBindingArguments, getQuorum, getTtl, isAutoBindDlq, isBindQueue, isDeclareDlx, isDeclareExchange, isDelayedExchange, isDlqLazy, isDlqSingleActiveConsumer, isExchangeAutoDelete, isExchangeDurable, isLazy, isQueueNameGroupOnly, isSingleActiveConsumer, setAutoBindDlq, setBindingRoutingKey, setBindingRoutingKeyDelimiter, setBindQueue, setDeadLetterExchange, setDeadLetterExchangeType, setDeadLetterQueueName, setDeadLetterRoutingKey, setDeclareDlx, setDeclareExchange, setDelayedExchange, setDlqBindingArguments, setDlqDeadLetterExchange, setDlqDeadLetterRoutingKey, setDlqExpires, setDlqLazy, setDlqMaxLength, setDlqMaxLengthBytes, setDlqMaxPriority, setDlqOverflowBehavior, setDlqQuorum, setDlqSingleActiveConsumer, setDlqTtl, setExchangeAutoDelete, setExchangeDurable, setExchangeType, setExpires, setLazy, setMaxLength, setMaxLengthBytes, setMaxPriority, setOverflowBehavior, setPrefix, setQueueBindingArguments, setQueueNameGroupOnly, setQuorum, setSingleActiveConsumer, setTtl

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitProducerProperties

public RabbitProducerProperties()

Method Detail

setRequestHeaderPatterns

@Deprecated
public void setRequestHeaderPatterns(String[] requestHeaderPatterns)

Deprecated. - use setHeaderPatterns(String[]).

Parameters:

requestHeaderPatterns - the patterns.

getRequestHeaderPatterns

@Deprecated
public String[] getRequestHeaderPatterns()

Deprecated. - use getHeaderPatterns().

Returns:

the header patterns.

setCompress

public void setCompress(boolean compress)

isCompress

public boolean isCompress()

setDeliveryMode

public void setDeliveryMode(org.springframework.amqp.core.MessageDeliveryMode deliveryMode)

getDeliveryMode

public org.springframework.amqp.core.MessageDeliveryMode getDeliveryMode()

getHeaderPatterns

public String[] getHeaderPatterns()

setHeaderPatterns

public void setHeaderPatterns(String[] replyHeaderPatterns)

isBatchingEnabled

public boolean isBatchingEnabled()

setBatchingEnabled

public void setBatchingEnabled(boolean batchingEnabled)

getBatchSize

@Min(value=1L,
     message="Batch Size should be greater than zero.")
public @Min(value=1L,message="Batch Size should be greater than zero.") int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getBatchBufferLimit

@Min(value=1L,
     message="Batch Buffer Limit should be greater than zero.")
public @Min(value=1L,message="Batch Buffer Limit should be greater than zero.") int getBatchBufferLimit()

setBatchBufferLimit

public void setBatchBufferLimit(int batchBufferLimit)

getBatchTimeout

@Min(value=1L,
     message="Batch Timeout should be greater than zero.")
public @Min(value=1L,message="Batch Timeout should be greater than zero.") int getBatchTimeout()

setBatchTimeout

public void setBatchTimeout(int batchTimeout)

isTransacted

public boolean isTransacted()

setTransacted

public void setTransacted(boolean transacted)

getDelayExpression

public org.springframework.expression.Expression getDelayExpression()

setDelayExpression

public void setDelayExpression(org.springframework.expression.Expression delayExpression)

getRoutingKeyExpression

public org.springframework.expression.Expression getRoutingKeyExpression()

setRoutingKeyExpression

public void setRoutingKeyExpression(org.springframework.expression.Expression routingKeyExpression)

getConfirmAckChannel

public String getConfirmAckChannel()

setConfirmAckChannel

public void setConfirmAckChannel(String confirmAckChannel)

getBatchingStrategyBeanName

public String getBatchingStrategyBeanName()

setBatchingStrategyBeanName

public void setBatchingStrategyBeanName(String batchingStrategyBeanName)