org.springframework.cloud.stream.binder

Class ConsumerProperties

java.lang.Object

org.springframework.cloud.stream.binder.ConsumerProperties

All Implemented Interfaces:

MergableProperties

Direct Known Subclasses:

ExtendedConsumerProperties

public class ConsumerProperties
extends Object
implements MergableProperties

Common consumer properties.

Author:

Marius Bogoevici, Ilayaperumal Gopinathan, Gary Russell, Soby Chacko, Oleg Zhurakousky

Constructor Summary

Constructors

Constructor and Description
ConsumerProperties()

Method Summary

Modifier and Type	Method and Description
@Min(value=1L,message="Backoff initial interval should be greater than zero.") int	getBackOffInitialInterval()
@Min(value=1L,message="Backoff max interval should be greater than zero.") int	getBackOffMaxInterval()
@Min(value=1L,message="Backoff multiplier should be greater than zero.") double	getBackOffMultiplier()
@Min(value=1L,message="Concurrency should be greater than zero.") int	getConcurrency()
HeaderMode	getHeaderMode()
@Min(value=1L,message="Instance count should be greater than zero.") int	getInstanceCount()
@Min(value=0L,message="Instance index should be greater than or equal to 0") int	getInstanceIndex()
@Min(value=1L,message="Max attempts should be greater than zero.") int	getMaxAttempts()
boolean	isPartitioned()
boolean	isUseNativeDecoding()
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)
void	setUseNativeDecoding(boolean useNativeDecoding)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.stream.config.MergableProperties

copyProperties, merge

Constructor Detail

ConsumerProperties

public ConsumerProperties()

Method Detail

getConcurrency

@Min(value=1L,
     message="Concurrency should be greater than zero.")
public @Min(value=1L,message="Concurrency should be greater than zero.") 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 @Min(value=1L,message="Instance count should be greater than zero.") int getInstanceCount()

setInstanceCount

public void setInstanceCount(int instanceCount)

getInstanceIndex

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

setInstanceIndex

public void setInstanceIndex(int instanceIndex)

getMaxAttempts

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

setMaxAttempts

public void setMaxAttempts(int maxAttempts)

getBackOffInitialInterval

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

setBackOffInitialInterval

public void setBackOffInitialInterval(int backOffInitialInterval)

getBackOffMaxInterval

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

setBackOffMaxInterval

public void setBackOffMaxInterval(int backOffMaxInterval)

getBackOffMultiplier

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

setBackOffMultiplier

public void setBackOffMultiplier(double backOffMultiplier)

getHeaderMode

public HeaderMode getHeaderMode()

setHeaderMode

public void setHeaderMode(HeaderMode headerMode)

isUseNativeDecoding

public boolean isUseNativeDecoding()

setUseNativeDecoding

public void setUseNativeDecoding(boolean useNativeDecoding)