org.springframework.cloud.stream.app.rabbit.source

Class RabbitSourceProperties

java.lang.Object

org.springframework.cloud.stream.app.rabbit.source.RabbitSourceProperties

@ConfigurationProperties(value="rabbit")
public class RabbitSourceProperties
extends Object

Properties for the Rabbit Source.

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
RabbitSourceProperties()

Method Summary

Modifier and Type	Method and Description
int	getInitialRetryInterval()
String[]	getMappedRequestHeaders()
int	getMaxAttempts()
int	getMaxRetryInterval()
String[]	getQueues()
boolean	getRequeue()
double	getRetryMultiplier()
boolean	getTransacted()
boolean	isEnableRetry()
void	setEnableRetry(boolean enableRetry)
void	setInitialRetryInterval(int initialRetryInterval)
void	setMappedRequestHeaders(String[] mappedRequestHeaders)
void	setMaxAttempts(int maxAttempts)
void	setMaxRetryInterval(int maxRetryInterval)
void	setQueues(String[] queues)
void	setRequeue(boolean requeue)
void	setRetryMultiplier(double retryMultiplier)
void	setTransacted(boolean transacted)

Methods inherited from class java.lang.Object

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

Constructor Detail

RabbitSourceProperties

public RabbitSourceProperties()

Method Detail

getRequeue

public boolean getRequeue()

setRequeue

public void setRequeue(boolean requeue)

getTransacted

public boolean getTransacted()

setTransacted

public void setTransacted(boolean transacted)

getQueues

@NotNull(message="queue(s) are required")
 @Size(min=1,
      message="At least one queue is required")
public String[] getQueues()

setQueues

public void setQueues(String[] queues)

getMappedRequestHeaders

@NotNull
public String[] getMappedRequestHeaders()

setMappedRequestHeaders

public void setMappedRequestHeaders(String[] mappedRequestHeaders)

getInitialRetryInterval

public int getInitialRetryInterval()

setInitialRetryInterval

public void setInitialRetryInterval(int initialRetryInterval)

getMaxRetryInterval

public int getMaxRetryInterval()

setMaxRetryInterval

public void setMaxRetryInterval(int maxRetryInterval)

getRetryMultiplier

public double getRetryMultiplier()

setRetryMultiplier

public void setRetryMultiplier(double retryMultiplier)

getMaxAttempts

public int getMaxAttempts()

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

isEnableRetry

public boolean isEnableRetry()

setEnableRetry

public void setEnableRetry(boolean enableRetry)