Package com.alibaba.cloud.stream.binder.rocketmq.properties

Class RocketMQProducerProperties

java.lang.Object

com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQCommonProperties

com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

All Implemented Interfaces:

Serializable

public class RocketMQProducerProperties
extends RocketMQCommonProperties

Extended producer properties for RocketMQ binder.

Author:

Jim

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RocketMQProducerProperties.ProducerType
static enum	RocketMQProducerProperties.SendType

Constructor Summary

Constructors

Constructor	Description
RocketMQProducerProperties()

Method Summary

Modifier and Type	Method	Description
String	getCheckForbiddenHook()
int	getCompressMsgBodyThreshold()
String	getErrorMessageStrategy()
int	getMaxMessageSize()
String	getMessageQueueSelector()
String	getProducerType()
boolean	getRetryAnotherBroker()
int	getRetryTimesWhenSendAsyncFailed()
int	getRetryTimesWhenSendFailed()
String	getSendCallBack()
String	getSendFailureChannel()
String	getSendMessageHook()
int	getSendMsgTimeout()
String	getSendType()
String	getTransactionListener()
void	setCheckForbiddenHook(String checkForbiddenHook)
void	setCompressMsgBodyThreshold(int compressMsgBodyThreshold)
void	setErrorMessageStrategy(String errorMessageStrategy)
void	setMaxMessageSize(int maxMessageSize)
void	setMessageQueueSelector(String messageQueueSelector)
void	setProducerType(String producerType)
void	setRetryAnotherBroker(boolean retryAnotherBroker)
void	setRetryTimesWhenSendAsyncFailed(int retryTimesWhenSendAsyncFailed)
void	setRetryTimesWhenSendFailed(int retryTimesWhenSendFailed)
void	setSendCallBack(String sendCallBack)
void	setSendFailureChannel(String sendFailureChannel)
void	setSendMessageHook(String sendMessageHook)
void	setSendMsgTimeout(int sendMsgTimeout)
void	setSendType(String sendType)
void	setTransactionListener(String transactionListener)

Methods inherited from class com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQCommonProperties

getAccessChannel, getAccessKey, getCustomizedTraceTopic, getEnabled, getEnableMsgTrace, getGroup, getHeartbeatBrokerInterval, getNameServer, getNamespace, getNamespaceV2, getPersistConsumerOffsetInterval, getPollNameServerInterval, getSecretKey, getUnitName, getUseTLS, getVipChannelEnabled, setAccessChannel, setAccessKey, setCustomizedTraceTopic, setEnabled, setEnableMsgTrace, setGroup, setHeartbeatBrokerInterval, setNameServer, setNamespace, setNamespaceV2, setPersistConsumerOffsetInterval, setPollNameServerInterval, setSecretKey, setUnitName, setUseTLS, setVipChannelEnabled

Methods inherited from class java.lang.Object

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

Constructor Details

RocketMQProducerProperties

public RocketMQProducerProperties()

Method Details

getSendMsgTimeout

public int getSendMsgTimeout()

setSendMsgTimeout

public void setSendMsgTimeout(int sendMsgTimeout)

getCompressMsgBodyThreshold

public int getCompressMsgBodyThreshold()

setCompressMsgBodyThreshold

public void setCompressMsgBodyThreshold(int compressMsgBodyThreshold)

getRetryTimesWhenSendFailed

public int getRetryTimesWhenSendFailed()

setRetryTimesWhenSendFailed

public void setRetryTimesWhenSendFailed(int retryTimesWhenSendFailed)

getRetryTimesWhenSendAsyncFailed

public int getRetryTimesWhenSendAsyncFailed()

setRetryTimesWhenSendAsyncFailed

public void setRetryTimesWhenSendAsyncFailed(int retryTimesWhenSendAsyncFailed)

getRetryAnotherBroker

public boolean getRetryAnotherBroker()

setRetryAnotherBroker

public void setRetryAnotherBroker(boolean retryAnotherBroker)

getMaxMessageSize

public int getMaxMessageSize()

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

getProducerType

public String getProducerType()

setProducerType

public void setProducerType(String producerType)

getSendType

public String getSendType()

setSendType

public void setSendType(String sendType)

getSendCallBack

public String getSendCallBack()

setSendCallBack

public void setSendCallBack(String sendCallBack)

getTransactionListener

public String getTransactionListener()

setTransactionListener

public void setTransactionListener(String transactionListener)

getMessageQueueSelector

public String getMessageQueueSelector()

setMessageQueueSelector

public void setMessageQueueSelector(String messageQueueSelector)

getErrorMessageStrategy

public String getErrorMessageStrategy()

setErrorMessageStrategy

public void setErrorMessageStrategy(String errorMessageStrategy)

getSendFailureChannel

public String getSendFailureChannel()

setSendFailureChannel

public void setSendFailureChannel(String sendFailureChannel)

getCheckForbiddenHook

public String getCheckForbiddenHook()

setCheckForbiddenHook

public void setCheckForbiddenHook(String checkForbiddenHook)

getSendMessageHook

public String getSendMessageHook()

setSendMessageHook

public void setSendMessageHook(String sendMessageHook)