public class RabbitConsumerProperties extends RabbitCommonProperties
DEAD_LETTER_EXCHANGE
Constructor and Description |
---|
RabbitConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
org.springframework.amqp.core.AcknowledgeMode |
getAcknowledgeMode() |
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() |
boolean |
isDurableSubscription() |
boolean |
isExclusive() |
boolean |
isRepublishToDlq() |
boolean |
isRequeueRejected() |
boolean |
isTransacted() |
void |
setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
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) |
getBindingRoutingKey, getDeadLetterExchange, getDeadLetterExchangeType, getDeadLetterQueueName, getDeadLetterRoutingKey, getDlqDeadLetterExchange, getDlqDeadLetterRoutingKey, getDlqExpires, getDlqMaxLength, getDlqMaxLengthBytes, getDlqMaxPriority, getDlqOverflowBehavior, getDlqTtl, getExchangeType, getExpires, getMaxLength, getMaxLengthBytes, getMaxPriority, getOverflowBehavior, getPrefix, getTtl, isAutoBindDlq, isBindQueue, isDeclareDlx, isDeclareExchange, isDelayedExchange, isDlqLazy, isExchangeAutoDelete, isExchangeDurable, isLazy, isQueueNameGroupOnly, setAutoBindDlq, setBindingRoutingKey, setBindQueue, setDeadLetterExchange, setDeadLetterExchangeType, setDeadLetterQueueName, setDeadLetterRoutingKey, setDeclareDlx, setDeclareExchange, setDelayedExchange, setDlqDeadLetterExchange, setDlqDeadLetterRoutingKey, setDlqExpires, setDlqLazy, setDlqMaxLength, setDlqMaxLengthBytes, setDlqMaxPriority, setDlqOverflowBehavior, setDlqTtl, setExchangeAutoDelete, setExchangeDurable, setExchangeType, setExpires, setLazy, setMaxLength, setMaxLengthBytes, setMaxPriority, setOverflowBehavior, setPrefix, setQueueNameGroupOnly, setTtl
public boolean isTransacted()
public void setTransacted(boolean transacted)
public org.springframework.amqp.core.AcknowledgeMode getAcknowledgeMode()
public void setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode)
@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()
public void setMaxConcurrency(int maxConcurrency)
@Min(value=1L, message="Prefetch should be greater than zero.") public @Min(value=1L,message="Prefetch should be greater than zero.") int getPrefetch()
public void setPrefetch(int prefetch)
@Deprecated public String[] getRequestHeaderPatterns()
getHeaderPatterns()
.@Deprecated public void setRequestHeaderPatterns(String[] requestHeaderPatterns)
setHeaderPatterns(String[])
.requestHeaderPatterns
- request header patterns@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()
public void setTxSize(int txSize)
public boolean isDurableSubscription()
public void setDurableSubscription(boolean durableSubscription)
public boolean isRepublishToDlq()
public void setRepublishToDlq(boolean republishToDlq)
public boolean isRequeueRejected()
public org.springframework.amqp.core.MessageDeliveryMode getRepublishDeliveyMode()
public void setRepublishDeliveyMode(org.springframework.amqp.core.MessageDeliveryMode republishDeliveyMode)
public void setRequeueRejected(boolean requeueRejected)
public String[] getHeaderPatterns()
public void setHeaderPatterns(String[] replyHeaderPatterns)
public long getRecoveryInterval()
public void setRecoveryInterval(long recoveryInterval)
public boolean isExclusive()
public void setExclusive(boolean exclusive)
public boolean getMissingQueuesFatal()
public void setMissingQueuesFatal(boolean missingQueuesFatal)
public Integer getQueueDeclarationRetries()
public void setQueueDeclarationRetries(Integer queueDeclarationRetries)
public Long getFailedDeclarationRetryInterval()
public void setFailedDeclarationRetryInterval(Long failedDeclarationRetryInterval)
public String getConsumerTagPrefix()
public void setConsumerTagPrefix(String consumerTagPrefix)
public int getFrameMaxHeadroom()
public void setFrameMaxHeadroom(int frameMaxHeadroom)
public org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType getContainerType()
public void setContainerType(org.springframework.boot.autoconfigure.amqp.RabbitProperties.ContainerType containerType)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.