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

Class RabbitCommonProperties

java.lang.Object

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

Direct Known Subclasses:

RabbitConsumerProperties, RabbitProducerProperties

public abstract class RabbitCommonProperties
extends Object

Since:

1.2

Author:

Gary Russell, Soby Chacko

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RabbitCommonProperties.QuorumConfig

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEAD_LETTER_EXCHANGE DLQ name prefix.

Constructor Summary

Constructors

Constructor and Description
RabbitCommonProperties()

Method Summary

Modifier and Type	Method and Description
String	getBindingRoutingKey()
String	getBindingRoutingKeyDelimiter()
String	getDeadLetterExchange()
String	getDeadLetterExchangeType()
String	getDeadLetterQueueName()
String	getDeadLetterRoutingKey()
Map<String,String>	getDlqBindingArguments()
String	getDlqDeadLetterExchange()
String	getDlqDeadLetterRoutingKey()
Integer	getDlqExpires()
Integer	getDlqMaxLength()
Integer	getDlqMaxLengthBytes()
Integer	getDlqMaxPriority()
String	getDlqOverflowBehavior()
RabbitCommonProperties.QuorumConfig	getDlqQuorum()
Integer	getDlqTtl()
String	getExchangeType()
Integer	getExpires()
Integer	getMaxLength()
Integer	getMaxLengthBytes()
@Range(min=0L,max=255L) Integer	getMaxPriority()
String	getOverflowBehavior()
String	getPrefix()
Map<String,String>	getQueueBindingArguments()
RabbitCommonProperties.QuorumConfig	getQuorum()
Integer	getTtl()
boolean	isAutoBindDlq()
boolean	isBindQueue()
boolean	isDeclareDlx()
boolean	isDeclareExchange()
boolean	isDelayedExchange()
boolean	isDlqLazy()
boolean	isDlqSingleActiveConsumer()
boolean	isExchangeAutoDelete()
boolean	isExchangeDurable()
boolean	isLazy()
boolean	isQueueNameGroupOnly()
boolean	isSingleActiveConsumer()
void	setAutoBindDlq(boolean autoBindDlq)
void	setBindingRoutingKey(String routingKey)
void	setBindingRoutingKeyDelimiter(String bindingRoutingKeyDelimiter)
void	setBindQueue(boolean bindQueue)
void	setDeadLetterExchange(String deadLetterExchange)
void	setDeadLetterExchangeType(String deadLetterExchangeType)
void	setDeadLetterQueueName(String deadLetterQueueName)
void	setDeadLetterRoutingKey(String deadLetterRoutingKey)
void	setDeclareDlx(boolean declareDlx)
void	setDeclareExchange(boolean declareExchange)
void	setDelayedExchange(boolean delayedExchange)
void	setDlqBindingArguments(Map<String,String> dlqBindingArguments)
void	setDlqDeadLetterExchange(String dlqDeadLetterExchange)
void	setDlqDeadLetterRoutingKey(String dlqDeadLetterRoutingKey)
void	setDlqExpires(Integer dlqExpires)
void	setDlqLazy(boolean dlqLazy)
void	setDlqMaxLength(Integer dlqMaxLength)
void	setDlqMaxLengthBytes(Integer dlqMaxLengthBytes)
void	setDlqMaxPriority(Integer dlqMaxPriority)
void	setDlqOverflowBehavior(String dlqOverflowBehavior)
void	setDlqQuorum(RabbitCommonProperties.QuorumConfig dlqQuorum)
void	setDlqSingleActiveConsumer(boolean dlqSingleActiveConsumer)
void	setDlqTtl(Integer dlqTtl)
void	setExchangeAutoDelete(boolean exchangeAutoDelete)
void	setExchangeDurable(boolean exchangeDurable)
void	setExchangeType(String exchangeType)
void	setExpires(Integer expires)
void	setLazy(boolean lazy)
void	setMaxLength(Integer maxLength)
void	setMaxLengthBytes(Integer maxLengthBytes)
void	setMaxPriority(Integer maxPriority)
void	setOverflowBehavior(String overflowBehavior)
void	setPrefix(String prefix)
void	setQueueBindingArguments(Map<String,String> queueBindingArguments)
void	setQueueNameGroupOnly(boolean queueNameGroupOnly)
void	setQuorum(RabbitCommonProperties.QuorumConfig quorum)
void	setSingleActiveConsumer(boolean singleActiveConsumer)
void	setTtl(Integer ttl)

Methods inherited from class java.lang.Object

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

Field Detail

DEAD_LETTER_EXCHANGE

public static final String DEAD_LETTER_EXCHANGE

DLQ name prefix.

See Also:

Constant Field Values

Constructor Detail

RabbitCommonProperties

public RabbitCommonProperties()

Method Detail

getExchangeType

public String getExchangeType()

setExchangeType

public void setExchangeType(String exchangeType)

isDeclareExchange

public boolean isDeclareExchange()

setDeclareExchange

public void setDeclareExchange(boolean declareExchange)

isExchangeDurable

public boolean isExchangeDurable()

setExchangeDurable

public void setExchangeDurable(boolean exchangeDurable)

isExchangeAutoDelete

public boolean isExchangeAutoDelete()

setExchangeAutoDelete

public void setExchangeAutoDelete(boolean exchangeAutoDelete)

isDelayedExchange

public boolean isDelayedExchange()

setDelayedExchange

public void setDelayedExchange(boolean delayedExchange)

isQueueNameGroupOnly

public boolean isQueueNameGroupOnly()

setQueueNameGroupOnly

public void setQueueNameGroupOnly(boolean queueNameGroupOnly)

isBindQueue

public boolean isBindQueue()

setBindQueue

public void setBindQueue(boolean bindQueue)

getBindingRoutingKey

public String getBindingRoutingKey()

setBindingRoutingKey

public void setBindingRoutingKey(String routingKey)

getBindingRoutingKeyDelimiter

public String getBindingRoutingKeyDelimiter()

setBindingRoutingKeyDelimiter

public void setBindingRoutingKeyDelimiter(String bindingRoutingKeyDelimiter)

getTtl

public Integer getTtl()

setTtl

public void setTtl(Integer ttl)

getExpires

public Integer getExpires()

setExpires

public void setExpires(Integer expires)

getMaxLength

public Integer getMaxLength()

setMaxLength

public void setMaxLength(Integer maxLength)

getMaxLengthBytes

public Integer getMaxLengthBytes()

setMaxLengthBytes

public void setMaxLengthBytes(Integer maxLengthBytes)

getMaxPriority

@Range(min=0L,
       max=255L)
public @Range(min=0L,max=255L) Integer getMaxPriority()

setMaxPriority

public void setMaxPriority(Integer maxPriority)

getDeadLetterQueueName

public String getDeadLetterQueueName()

setDeadLetterQueueName

public void setDeadLetterQueueName(String deadLetterQueueName)

getDeadLetterExchange

public String getDeadLetterExchange()

setDeadLetterExchange

public void setDeadLetterExchange(String deadLetterExchange)

getDeadLetterExchangeType

public String getDeadLetterExchangeType()

setDeadLetterExchangeType

public void setDeadLetterExchangeType(String deadLetterExchangeType)

isDeclareDlx

public boolean isDeclareDlx()

setDeclareDlx

public void setDeclareDlx(boolean declareDlx)

getDeadLetterRoutingKey

public String getDeadLetterRoutingKey()

setDeadLetterRoutingKey

public void setDeadLetterRoutingKey(String deadLetterRoutingKey)

getDlqTtl

public Integer getDlqTtl()

setDlqTtl

public void setDlqTtl(Integer dlqTtl)

getDlqExpires

public Integer getDlqExpires()

setDlqExpires

public void setDlqExpires(Integer dlqExpires)

getDlqMaxLength

public Integer getDlqMaxLength()

setDlqMaxLength

public void setDlqMaxLength(Integer dlqMaxLength)

getDlqMaxLengthBytes

public Integer getDlqMaxLengthBytes()

setDlqMaxLengthBytes

public void setDlqMaxLengthBytes(Integer dlqMaxLengthBytes)

getDlqMaxPriority

public Integer getDlqMaxPriority()

setDlqMaxPriority

public void setDlqMaxPriority(Integer dlqMaxPriority)

getDlqDeadLetterExchange

public String getDlqDeadLetterExchange()

setDlqDeadLetterExchange

public void setDlqDeadLetterExchange(String dlqDeadLetterExchange)

getDlqDeadLetterRoutingKey

public String getDlqDeadLetterRoutingKey()

setDlqDeadLetterRoutingKey

public void setDlqDeadLetterRoutingKey(String dlqDeadLetterRoutingKey)

isAutoBindDlq

public boolean isAutoBindDlq()

setAutoBindDlq

public void setAutoBindDlq(boolean autoBindDlq)

getPrefix

public String getPrefix()

setPrefix

public void setPrefix(String prefix)

isLazy

public boolean isLazy()

setLazy

public void setLazy(boolean lazy)

isDlqLazy

public boolean isDlqLazy()

setDlqLazy

public void setDlqLazy(boolean dlqLazy)

getOverflowBehavior

public String getOverflowBehavior()

setOverflowBehavior

public void setOverflowBehavior(String overflowBehavior)

getDlqOverflowBehavior

public String getDlqOverflowBehavior()

setDlqOverflowBehavior

public void setDlqOverflowBehavior(String dlqOverflowBehavior)

getQueueBindingArguments

public Map<String,String> getQueueBindingArguments()

setQueueBindingArguments

public void setQueueBindingArguments(Map<String,String> queueBindingArguments)

getDlqBindingArguments

public Map<String,String> getDlqBindingArguments()

setDlqBindingArguments

public void setDlqBindingArguments(Map<String,String> dlqBindingArguments)

getQuorum

public RabbitCommonProperties.QuorumConfig getQuorum()

setQuorum

public void setQuorum(RabbitCommonProperties.QuorumConfig quorum)

getDlqQuorum

public RabbitCommonProperties.QuorumConfig getDlqQuorum()

setDlqQuorum

public void setDlqQuorum(RabbitCommonProperties.QuorumConfig dlqQuorum)

isSingleActiveConsumer

public boolean isSingleActiveConsumer()

setSingleActiveConsumer

public void setSingleActiveConsumer(boolean singleActiveConsumer)

isDlqSingleActiveConsumer

public boolean isDlqSingleActiveConsumer()

setDlqSingleActiveConsumer

public void setDlqSingleActiveConsumer(boolean dlqSingleActiveConsumer)