io.jboot.components.mq.rocketmq

类 JbootRocketmqConfig

java.lang.Object

io.jboot.components.mq.rocketmq.JbootRocketmqConfig

所有已实现的接口:

Serializable

public class JbootRocketmqConfig
extends Object
implements Serializable

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
private String	broadcastChannelPrefix
private String	clientIP
private Integer	consumeMessageBatchMaxSize
private String	consumerGroup
private String	createTopicKey
private String	instanceName
private String	namespace
private String	namesrvAddr
private String	producerGroup
private Boolean	retryAnotherBrokerWhenNotStoreOK
private Integer	retryTimesWhenSendAsyncFailed
private Integer	retryTimesWhenSendFailed
private Boolean	sendLatencyFaultEnable
private Boolean	sendMessageWithVIPChannel
private Integer	sendMsgTimeout
private String	subscribeSubExpression
private Boolean	useTLS

构造器概要

构造器

构造器和说明
JbootRocketmqConfig()

方法概要

限定符和类型	方法和说明
String	getBroadcastChannelPrefix()
String	getClientIP()
Integer	getConsumeMessageBatchMaxSize()
String	getConsumerGroup()
String	getCreateTopicKey()
String	getInstanceName()
String	getNamespace()
String	getNamesrvAddr()
String	getProducerGroup()
Boolean	getRetryAnotherBrokerWhenNotStoreOK()
Integer	getRetryTimesWhenSendAsyncFailed()
Integer	getRetryTimesWhenSendFailed()
Boolean	getSendLatencyFaultEnable()
Boolean	getSendMessageWithVIPChannel()
Integer	getSendMsgTimeout()
String	getSubscribeSubExpression()
Boolean	getUseTLS()
void	setBroadcastChannelPrefix(String broadcastChannelPrefix)
void	setClientIP(String clientIP)
void	setConsumeMessageBatchMaxSize(Integer consumeMessageBatchMaxSize)
void	setConsumerGroup(String consumerGroup)
void	setCreateTopicKey(String createTopicKey)
void	setInstanceName(String instanceName)
void	setNamespace(String namespace)
void	setNamesrvAddr(String namesrvAddr)
void	setProducerGroup(String producerGroup)
void	setRetryAnotherBrokerWhenNotStoreOK(Boolean retryAnotherBrokerWhenNotStoreOK)
void	setRetryTimesWhenSendAsyncFailed(Integer retryTimesWhenSendAsyncFailed)
void	setRetryTimesWhenSendFailed(Integer retryTimesWhenSendFailed)
void	setSendLatencyFaultEnable(Boolean sendLatencyFaultEnable)
void	setSendMessageWithVIPChannel(Boolean sendMessageWithVIPChannel)
void	setSendMsgTimeout(Integer sendMsgTimeout)
void	setSubscribeSubExpression(String subscribeSubExpression)
void	setUseTLS(Boolean useTLS)

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

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

字段详细资料

namesrvAddr

private String namesrvAddr

namespace

private String namespace

consumerGroup

private String consumerGroup

consumeMessageBatchMaxSize

private Integer consumeMessageBatchMaxSize

broadcastChannelPrefix

private String broadcastChannelPrefix

subscribeSubExpression

private String subscribeSubExpression

producerGroup

private String producerGroup

instanceName

private String instanceName

clientIP

private String clientIP

createTopicKey

private String createTopicKey

useTLS

private Boolean useTLS

sendLatencyFaultEnable

private Boolean sendLatencyFaultEnable

sendMessageWithVIPChannel

private Boolean sendMessageWithVIPChannel

sendMsgTimeout

private Integer sendMsgTimeout

retryAnotherBrokerWhenNotStoreOK

private Boolean retryAnotherBrokerWhenNotStoreOK

retryTimesWhenSendAsyncFailed

private Integer retryTimesWhenSendAsyncFailed

retryTimesWhenSendFailed

private Integer retryTimesWhenSendFailed

构造器详细资料

JbootRocketmqConfig

public JbootRocketmqConfig()

方法详细资料

getNamesrvAddr

public String getNamesrvAddr()

setNamesrvAddr

public void setNamesrvAddr(String namesrvAddr)

getNamespace

public String getNamespace()

setNamespace

public void setNamespace(String namespace)

getConsumerGroup

public String getConsumerGroup()

setConsumerGroup

public void setConsumerGroup(String consumerGroup)

getConsumeMessageBatchMaxSize

public Integer getConsumeMessageBatchMaxSize()

setConsumeMessageBatchMaxSize

public void setConsumeMessageBatchMaxSize(Integer consumeMessageBatchMaxSize)

getBroadcastChannelPrefix

public String getBroadcastChannelPrefix()

setBroadcastChannelPrefix

public void setBroadcastChannelPrefix(String broadcastChannelPrefix)

getSubscribeSubExpression

public String getSubscribeSubExpression()

setSubscribeSubExpression

public void setSubscribeSubExpression(String subscribeSubExpression)

getProducerGroup

public String getProducerGroup()

setProducerGroup

public void setProducerGroup(String producerGroup)

getInstanceName

public String getInstanceName()

setInstanceName

public void setInstanceName(String instanceName)

getClientIP

public String getClientIP()

setClientIP

public void setClientIP(String clientIP)

getCreateTopicKey

public String getCreateTopicKey()

setCreateTopicKey

public void setCreateTopicKey(String createTopicKey)

getUseTLS

public Boolean getUseTLS()

setUseTLS

public void setUseTLS(Boolean useTLS)

getSendLatencyFaultEnable

public Boolean getSendLatencyFaultEnable()

setSendLatencyFaultEnable

public void setSendLatencyFaultEnable(Boolean sendLatencyFaultEnable)

getSendMessageWithVIPChannel

public Boolean getSendMessageWithVIPChannel()

setSendMessageWithVIPChannel

public void setSendMessageWithVIPChannel(Boolean sendMessageWithVIPChannel)

getSendMsgTimeout

public Integer getSendMsgTimeout()

setSendMsgTimeout

public void setSendMsgTimeout(Integer sendMsgTimeout)

getRetryAnotherBrokerWhenNotStoreOK

public Boolean getRetryAnotherBrokerWhenNotStoreOK()

setRetryAnotherBrokerWhenNotStoreOK

public void setRetryAnotherBrokerWhenNotStoreOK(Boolean retryAnotherBrokerWhenNotStoreOK)

getRetryTimesWhenSendAsyncFailed

public Integer getRetryTimesWhenSendAsyncFailed()

setRetryTimesWhenSendAsyncFailed

public void setRetryTimesWhenSendAsyncFailed(Integer retryTimesWhenSendAsyncFailed)

getRetryTimesWhenSendFailed

public Integer getRetryTimesWhenSendFailed()

setRetryTimesWhenSendFailed

public void setRetryTimesWhenSendFailed(Integer retryTimesWhenSendFailed)