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

Class RabbitConsumerProperties

java.lang.Object

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

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

public class RabbitConsumerProperties
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
RabbitConsumerProperties()

Method Summary

Modifier and Type	Method and Description
org.springframework.amqp.core.AcknowledgeMode	getAcknowledgeMode()
String	getAnonymousGroupPrefix()
@Min(value=1L,message="Batch Size should be greater than zero.") int	getBatchSize()
String	getConsumerTagPrefix()
org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType	getContainerType()
Long	getFailedDeclarationRetryInterval()
int	getFrameMaxHeadroom()
String[]	getHeaderPatterns()
@Min(value=1L,message="Max Concurrency should be greater than zero.") int	getMaxConcurrency()
boolean	getMissingQueuesFatal()
@Min(value=1L,message="Prefetch should be greater than zero.") int	getPrefetch()
Integer	getQueueDeclarationRetries()
long	getRecoveryInterval()
org.springframework.amqp.core.MessageDeliveryMode	getRepublishDeliveyMode()
String[]	getRequestHeaderPatterns() Deprecated. - use getHeaderPatterns().
@Min(value=1L,message="Tx Size should be greater than zero.") int	getTxSize() Deprecated. in favor of getBatchSize()
boolean	isDurableSubscription()
boolean	isExclusive()
boolean	isRepublishToDlq()
boolean	isRequeueRejected()
boolean	isTransacted()
void	setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
void	setAnonymousGroupPrefix(String anonymousGroupPrefix)
void	setBatchSize(int batchSize)
void	setConsumerTagPrefix(String consumerTagPrefix)
void	setContainerType(org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType containerType)
void	setDurableSubscription(boolean durableSubscription)
void	setExclusive(boolean exclusive)
void	setFailedDeclarationRetryInterval(Long failedDeclarationRetryInterval)
void	setFrameMaxHeadroom(int frameMaxHeadroom)
void	setHeaderPatterns(String[] replyHeaderPatterns)
void	setMaxConcurrency(int maxConcurrency)
void	setMissingQueuesFatal(boolean missingQueuesFatal)
void	setPrefetch(int prefetch)
void	setQueueDeclarationRetries(Integer queueDeclarationRetries)
void	setRecoveryInterval(long recoveryInterval)
void	setRepublishDeliveyMode(org.springframework.amqp.core.MessageDeliveryMode republishDeliveyMode)
void	setRepublishToDlq(boolean republishToDlq)
void	setRequestHeaderPatterns(String[] requestHeaderPatterns) Deprecated. - use setHeaderPatterns(String[]).
void	setRequeueRejected(boolean requeueRejected)
void	setTransacted(boolean transacted)
void	setTxSize(int txSize) deprecated in favor of setBatchSize(int).

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

RabbitConsumerProperties

public RabbitConsumerProperties()

Method Detail

isTransacted

public boolean isTransacted()

setTransacted

public void setTransacted(boolean transacted)

getAcknowledgeMode

public org.springframework.amqp.core.AcknowledgeMode getAcknowledgeMode()

setAcknowledgeMode

public void setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)

getMaxConcurrency

@Min(value=1L,
     message="Max Concurrency should be greater than zero.")
public @Min(value=1L,message="Max Concurrency should be greater than zero.") int getMaxConcurrency()

setMaxConcurrency

public void setMaxConcurrency(int maxConcurrency)

getPrefetch

@Min(value=1L,
     message="Prefetch should be greater than zero.")
public @Min(value=1L,message="Prefetch should be greater than zero.") int getPrefetch()

setPrefetch

public void setPrefetch(int prefetch)

getRequestHeaderPatterns

@Deprecated
public String[] getRequestHeaderPatterns()

Deprecated. - use getHeaderPatterns().

Returns:

the header patterns.

setRequestHeaderPatterns

@Deprecated
public void setRequestHeaderPatterns(String[] requestHeaderPatterns)

Deprecated. - use setHeaderPatterns(String[]).

Parameters:

requestHeaderPatterns - request header patterns

getTxSize

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

Deprecated. in favor of getBatchSize()

Returns:

the tx size.

setTxSize

public void setTxSize(int txSize)

deprecated in favor of setBatchSize(int).

Parameters:

txSize - the tx size

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)

isDurableSubscription

public boolean isDurableSubscription()

setDurableSubscription

public void setDurableSubscription(boolean durableSubscription)

isRepublishToDlq

public boolean isRepublishToDlq()

setRepublishToDlq

public void setRepublishToDlq(boolean republishToDlq)

isRequeueRejected

public boolean isRequeueRejected()

getRepublishDeliveyMode

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

setRepublishDeliveyMode

public void setRepublishDeliveyMode(org.springframework.amqp.core.MessageDeliveryMode republishDeliveyMode)

setRequeueRejected

public void setRequeueRejected(boolean requeueRejected)

getHeaderPatterns

public String[] getHeaderPatterns()

setHeaderPatterns

public void setHeaderPatterns(String[] replyHeaderPatterns)

getRecoveryInterval

public long getRecoveryInterval()

setRecoveryInterval

public void setRecoveryInterval(long recoveryInterval)

isExclusive

public boolean isExclusive()

setExclusive

public void setExclusive(boolean exclusive)

getMissingQueuesFatal

public boolean getMissingQueuesFatal()

setMissingQueuesFatal

public void setMissingQueuesFatal(boolean missingQueuesFatal)

getQueueDeclarationRetries

public Integer getQueueDeclarationRetries()

setQueueDeclarationRetries

public void setQueueDeclarationRetries(Integer queueDeclarationRetries)

getFailedDeclarationRetryInterval

public Long getFailedDeclarationRetryInterval()

setFailedDeclarationRetryInterval

public void setFailedDeclarationRetryInterval(Long failedDeclarationRetryInterval)

getConsumerTagPrefix

public String getConsumerTagPrefix()

setConsumerTagPrefix

public void setConsumerTagPrefix(String consumerTagPrefix)

getFrameMaxHeadroom

public int getFrameMaxHeadroom()

setFrameMaxHeadroom

public void setFrameMaxHeadroom(int frameMaxHeadroom)

getContainerType

public org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType getContainerType()

setContainerType

public void setContainerType(org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType containerType)

getAnonymousGroupPrefix

public String getAnonymousGroupPrefix()

setAnonymousGroupPrefix

public void setAnonymousGroupPrefix(String anonymousGroupPrefix)