org.springframework.cloud.stream.binder

Class ConsumerProperties

java.lang.Object

org.springframework.cloud.stream.binder.ConsumerProperties

Direct Known Subclasses:

ExtendedConsumerProperties

public class ConsumerProperties
extends Object

Common consumer properties.

Author:

Marius Bogoevici, Ilayaperumal Gopinathan

Constructor Summary

Constructors

Constructor and Description
ConsumerProperties()

Method Summary

Modifier and Type	Method and Description
int	getBackOffInitialInterval()
int	getBackOffMaxInterval()
double	getBackOffMultiplier()
int	getConcurrency()
HeaderMode	getHeaderMode()
int	getInstanceCount()
int	getInstanceIndex()
int	getMaxAttempts()
boolean	isPartitioned()
void	setBackOffInitialInterval(int backOffInitialInterval)
void	setBackOffMaxInterval(int backOffMaxInterval)
void	setBackOffMultiplier(double backOffMultiplier)
void	setConcurrency(int concurrency)
void	setHeaderMode(HeaderMode headerMode)
void	setInstanceCount(int instanceCount)
void	setInstanceIndex(int instanceIndex)
void	setMaxAttempts(int maxAttempts)
void	setPartitioned(boolean partitioned)

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerProperties

public ConsumerProperties()

Method Detail

getConcurrency

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

setConcurrency

public void setConcurrency(int concurrency)

isPartitioned

public boolean isPartitioned()

setPartitioned

public void setPartitioned(boolean partitioned)

getInstanceCount

@Min(value=1L,
     message="Instance count should be greater than zero.")
public int getInstanceCount()

setInstanceCount

public void setInstanceCount(int instanceCount)

getInstanceIndex

@Min(value=0L,
     message="Instance index should be greater than or equal to 0")
public int getInstanceIndex()

setInstanceIndex

public void setInstanceIndex(int instanceIndex)

getMaxAttempts

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

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

getBackOffInitialInterval

@Min(value=1L,
     message="Backoff initial interval should be greater than zero.")
public int getBackOffInitialInterval()

setBackOffInitialInterval

public void setBackOffInitialInterval(int backOffInitialInterval)

getBackOffMaxInterval

@Min(value=1L,
     message="Backoff max interval should be greater than zero.")
public int getBackOffMaxInterval()

setBackOffMaxInterval

public void setBackOffMaxInterval(int backOffMaxInterval)

getBackOffMultiplier

@Min(value=1L,
     message="Backoff multiplier should be greater than zero.")
public double getBackOffMultiplier()

setBackOffMultiplier

public void setBackOffMultiplier(double backOffMultiplier)

getHeaderMode

public HeaderMode getHeaderMode()

setHeaderMode

public void setHeaderMode(HeaderMode headerMode)