org.joyqueue.model.domain

类 ConsumerConfig

java.lang.Object

org.joyqueue.model.domain.nsr.BaseNsrModel

org.joyqueue.model.domain.ConsumerConfig

所有已实现的接口:

Serializable, Cloneable

public class ConsumerConfig
extends BaseNsrModel

另请参阅:

序列化表格

字段概要

从类继承的字段 org.joyqueue.model.domain.nsr.BaseNsrModel

id

构造器概要

构造器

构造器和说明
ConsumerConfig()

方法概要

限定符和类型	方法和说明
int	getAckTimeout()
double	getBackOffMultiplier()
int	getBatchSize()
String	getBlackList()
int	getConcurrent()
String	getConsumerId()
int	getDelay()
int	getExpireTime()
String	getFilters()
int	getLimitTps()
int	getLimitTraffic()
int	getMaxRetryDelay()
int	getMaxRetrys()
OffsetMode	getOffsetMode()
int	getRetryDelay()
boolean	isArchive()
boolean	isNearBy()
boolean	isPaused()
boolean	isRetry()
boolean	isUseExponentialBackOff()
void	setAckTimeout(int ackTimeout)
void	setArchive(boolean archive)
void	setBackOffMultiplier(double backOffMultiplier)
void	setBatchSize(int batchSize)
void	setBlackList(String blackList)
void	setConcurrent(int concurrent)
void	setConsumerId(String consumerId)
void	setDelay(int delay)
void	setExpireTime(int expireTime)
void	setFilters(String filters)
void	setLimitTps(int limitTps)
void	setLimitTraffic(int limitTraffic)
void	setMaxRetryDelay(int maxRetryDelay)
void	setMaxRetrys(int maxRetrys)
void	setNearBy(boolean nearBy)
void	setOffsetMode(OffsetMode offsetMode)
void	setPaused(boolean paused)
void	setRetry(boolean retry)
void	setRetryDelay(int retryDelay)
void	setUseExponentialBackOff(boolean useExponentialBackOff)

从类继承的方法 org.joyqueue.model.domain.nsr.BaseNsrModel

getId, setId, toString

从类继承的方法 java.lang.Object

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

构造器详细资料

ConsumerConfig

public ConsumerConfig()

方法详细资料

isNearBy

public boolean isNearBy()

setNearBy

public void setNearBy(boolean nearBy)

getConsumerId

public String getConsumerId()

setConsumerId

public void setConsumerId(String consumerId)

isPaused

public boolean isPaused()

setPaused

public void setPaused(boolean paused)

isArchive

public boolean isArchive()

setArchive

public void setArchive(boolean archive)

isRetry

public boolean isRetry()

setRetry

public void setRetry(boolean retry)

getDelay

public int getDelay()

setDelay

public void setDelay(int delay)

getAckTimeout

public int getAckTimeout()

setAckTimeout

public void setAckTimeout(int ackTimeout)

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getMaxRetrys

public int getMaxRetrys()

setMaxRetrys

public void setMaxRetrys(int maxRetrys)

getMaxRetryDelay

public int getMaxRetryDelay()

setMaxRetryDelay

public void setMaxRetryDelay(int maxRetryDelay)

getRetryDelay

public int getRetryDelay()

setRetryDelay

public void setRetryDelay(int retryDelay)

isUseExponentialBackOff

public boolean isUseExponentialBackOff()

setUseExponentialBackOff

public void setUseExponentialBackOff(boolean useExponentialBackOff)

getBackOffMultiplier

public double getBackOffMultiplier()

setBackOffMultiplier

public void setBackOffMultiplier(double backOffMultiplier)

getExpireTime

public int getExpireTime()

setExpireTime

public void setExpireTime(int expireTime)

getConcurrent

public int getConcurrent()

setConcurrent

public void setConcurrent(int concurrent)

getBlackList

public String getBlackList()

setBlackList

public void setBlackList(String blackList)

getFilters

public String getFilters()

setFilters

public void setFilters(String filters)

setLimitTps

public void setLimitTps(int limitTps)

getLimitTps

public int getLimitTps()

setLimitTraffic

public void setLimitTraffic(int limitTraffic)

getLimitTraffic

public int getLimitTraffic()

getOffsetMode

public OffsetMode getOffsetMode()

setOffsetMode

public void setOffsetMode(OffsetMode offsetMode)