org.joyqueue.client.internal.producer.config

类 ProducerConfig

java.lang.Object

org.joyqueue.client.internal.producer.config.ProducerConfig

public class ProducerConfig
extends Object

ProducerConfig author: gaohaoxiang date: 2018/12/10

字段概要

字段

限定符和类型	字段和说明
static long	NONE_PRODUCE_TIMEOUT

构造器概要

构造器

构造器和说明
ProducerConfig()

方法概要

限定符和类型	方法和说明
ProducerConfig	copy()
String	getApp()
int	getBatchBodyLengthLimit()
int	getBodyLengthLimit()
int	getBusinessIdLengthLimit()
int	getCompressThreshold()
String	getCompressType()
long	getProduceTimeout()
org.joyqueue.domain.QosLevel	getQosLevel()
RetryPolicy	getRetryPolicy()
String	getSelectorType()
long	getTimeout()
long	getTransactionTimeout()
boolean	isBatch()
boolean	isCompress()
boolean	isFailover()
void	setApp(String app)
void	setBatch(boolean batch)
void	setBatchBodyLengthLimit(int batchBodyLengthLimit)
void	setBodyLengthLimit(int bodyLengthLimit)
void	setBusinessIdLengthLimit(int businessIdLengthLimit)
void	setCompress(boolean compress)
void	setCompressThreshold(int compressThreshold)
void	setCompressType(String compressType)
void	setFailover(boolean failover)
void	setProduceTimeout(long produceTimeout)
void	setQosLevel(org.joyqueue.domain.QosLevel qosLevel)
void	setRetryPolicy(RetryPolicy retryPolicy)
void	setSelectorType(String selectorType)
void	setTimeout(long timeout)
void	setTransactionTimeout(long transactionTimeout)

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

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

字段详细资料

NONE_PRODUCE_TIMEOUT

public static final long NONE_PRODUCE_TIMEOUT

另请参阅:

常量字段值

构造器详细资料

ProducerConfig

public ProducerConfig()

方法详细资料

copy

public ProducerConfig copy()

getApp

public String getApp()

setApp

public void setApp(String app)

getTimeout

public long getTimeout()

setTimeout

public void setTimeout(long timeout)

getProduceTimeout

public long getProduceTimeout()

setProduceTimeout

public void setProduceTimeout(long produceTimeout)

getTransactionTimeout

public long getTransactionTimeout()

setTransactionTimeout

public void setTransactionTimeout(long transactionTimeout)

isFailover

public boolean isFailover()

setFailover

public void setFailover(boolean failover)

getRetryPolicy

public RetryPolicy getRetryPolicy()

setRetryPolicy

public void setRetryPolicy(RetryPolicy retryPolicy)

getQosLevel

public org.joyqueue.domain.QosLevel getQosLevel()

setQosLevel

public void setQosLevel(org.joyqueue.domain.QosLevel qosLevel)

setCompress

public void setCompress(boolean compress)

isCompress

public boolean isCompress()

setCompressType

public void setCompressType(String compressType)

getCompressType

public String getCompressType()

setCompressThreshold

public void setCompressThreshold(int compressThreshold)

getCompressThreshold

public int getCompressThreshold()

setBatch

public void setBatch(boolean batch)

isBatch

public boolean isBatch()

getSelectorType

public String getSelectorType()

setSelectorType

public void setSelectorType(String selectorType)

getBusinessIdLengthLimit

public int getBusinessIdLengthLimit()

setBusinessIdLengthLimit

public void setBusinessIdLengthLimit(int businessIdLengthLimit)

getBodyLengthLimit

public int getBodyLengthLimit()

setBodyLengthLimit

public void setBodyLengthLimit(int bodyLengthLimit)

getBatchBodyLengthLimit

public int getBatchBodyLengthLimit()

setBatchBodyLengthLimit

public void setBatchBodyLengthLimit(int batchBodyLengthLimit)