public class RabbitConsumerProperties extends Object
Constructor and Description |
---|
RabbitConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
org.springframework.amqp.core.AcknowledgeMode |
getAcknowledgeMode() |
int |
getMaxConcurrency() |
int |
getPrefetch() |
String |
getPrefix() |
long |
getRecoveryInterval() |
String[] |
getReplyHeaderPatterns() |
String[] |
getRequestHeaderPatterns() |
int |
getTxSize() |
boolean |
isAutoBindDlq() |
boolean |
isDurableSubscription() |
boolean |
isRepublishToDlq() |
boolean |
isRequeueRejected() |
boolean |
isTransacted() |
void |
setAcknowledgeMode(org.springframework.amqp.core.AcknowledgeMode acknowledgeMode) |
void |
setAutoBindDlq(boolean autoBindDlq) |
void |
setDurableSubscription(boolean durableSubscription) |
void |
setMaxConcurrency(int maxConcurrency) |
void |
setPrefetch(int prefetch) |
void |
setPrefix(String prefix) |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setReplyHeaderPatterns(String[] replyHeaderPatterns) |
void |
setRepublishToDlq(boolean republishToDlq) |
void |
setRequestHeaderPatterns(String[] requestHeaderPatterns) |
void |
setRequeueRejected(boolean requeueRejected) |
void |
setTransacted(boolean transacted) |
void |
setTxSize(int txSize) |
public String getPrefix()
public void setPrefix(String prefix)
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 int getMaxConcurrency()
public void setMaxConcurrency(int maxConcurrency)
@Min(value=1L, message="Prefetch should be greater than zero.") public int getPrefetch()
public void setPrefetch(int prefetch)
public String[] getRequestHeaderPatterns()
public void setRequestHeaderPatterns(String[] requestHeaderPatterns)
@Min(value=1L, message="Tx Size should be greater than zero.") public int getTxSize()
public void setTxSize(int txSize)
public boolean isAutoBindDlq()
public void setAutoBindDlq(boolean autoBindDlq)
public boolean isDurableSubscription()
public void setDurableSubscription(boolean durableSubscription)
public boolean isRepublishToDlq()
public void setRepublishToDlq(boolean republishToDlq)
public boolean isRequeueRejected()
public void setRequeueRejected(boolean requeueRejected)
public String[] getReplyHeaderPatterns()
public void setReplyHeaderPatterns(String[] replyHeaderPatterns)
public long getRecoveryInterval()
public void setRecoveryInterval(long recoveryInterval)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.