org.zodiac.rocketmq.client.producer

类 RocketMQTransactionProducer

java.lang.Object

org.apache.rocketmq.client.ClientConfig

org.apache.rocketmq.client.producer.DefaultMQProducer

org.apache.rocketmq.client.producer.TransactionMQProducer

org.zodiac.rocketmq.client.producer.RocketMQTransactionProducer

所有已实现的接口:

org.apache.rocketmq.client.MQAdmin, org.apache.rocketmq.client.producer.MQProducer

public class RocketMQTransactionProducer
extends org.apache.rocketmq.client.producer.TransactionMQProducer

字段概要

字段

限定符和类型	字段和说明
private String	accessKey The property of "access-key".
private String	customizedTraceTopic
private boolean	enableAcl
private boolean	enableMsgTrace Switch flag instance for message trace.
private org.apache.rocketmq.logging.InternalLogger	log
private String	secretKey The property of "secret-key".

从类继承的字段 org.apache.rocketmq.client.producer.DefaultMQProducer

defaultMQProducerImpl

从类继承的字段 org.apache.rocketmq.client.ClientConfig

accessChannel, namespace, SEND_MESSAGE_WITH_VIP_CHANNEL_PROPERTY

构造器概要

构造器

构造器和说明
RocketMQTransactionProducer()
RocketMQTransactionProducer(String producerGroup)
RocketMQTransactionProducer(String producerGroup, org.apache.rocketmq.remoting.RPCHook rpcHook)
RocketMQTransactionProducer(String namespace, String producerGroup)
RocketMQTransactionProducer(String namespace, String producerGroup, org.apache.rocketmq.remoting.RPCHook rpcHook)
RocketMQTransactionProducer(String namespace, String producerGroup, org.apache.rocketmq.remoting.RPCHook rpcHook, boolean enableMsgTrace, String customizedTraceTopic)

方法概要

限定符和类型	方法和说明
String	getAccessKey()
String	getCustomizedTraceTopic()
String	getSecretKey()
void	initialize()
boolean	isEnableAcl()
boolean	isEnableMsgTrace()
private void	registerHooks()
private void	registerTraceHook()
void	setAccessKey(String accessKey)
void	setCustomizedTraceTopic(String customizedTraceTopic)
void	setEnableAcl(boolean enableAcl)
void	setEnableMsgTrace(boolean enableMsgTrace)
void	setSecretKey(String secretKey)
void	uninitialize()

从类继承的方法 org.apache.rocketmq.client.producer.TransactionMQProducer

getCheckRequestHoldMax, getCheckThreadPoolMaxSize, getCheckThreadPoolMinSize, getExecutorService, getTransactionCheckListener, getTransactionListener, sendMessageInTransaction, sendMessageInTransaction, setCheckRequestHoldMax, setCheckThreadPoolMaxSize, setCheckThreadPoolMinSize, setExecutorService, setTransactionCheckListener, setTransactionListener, shutdown, start

从类继承的方法 org.apache.rocketmq.client.producer.DefaultMQProducer

createTopic, createTopic, earliestMsgStoreTime, fetchPublishMessageQueues, getCompressMsgBodyOverHowmuch, getCreateTopicKey, getDefaultMQProducerImpl, getDefaultTopicQueueNums, getLatencyMax, getMaxMessageSize, getNotAvailableDuration, getProducerGroup, getRetryTimesWhenSendAsyncFailed, getRetryTimesWhenSendFailed, getSendMsgTimeout, getTraceDispatcher, isRetryAnotherBrokerWhenNotStoreOK, isSendLatencyFaultEnable, isSendMessageWithVIPChannel, maxOffset, minOffset, queryMessage, request, request, request, request, request, request, searchOffset, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, send, sendOneway, sendOneway, sendOneway, setAsyncSenderExecutor, setCallbackExecutor, setCompressMsgBodyOverHowmuch, setCreateTopicKey, setDefaultTopicQueueNums, setLatencyMax, setMaxMessageSize, setNotAvailableDuration, setProducerGroup, setRetryAnotherBrokerWhenNotStoreOK, setRetryTimesWhenSendAsyncFailed, setRetryTimesWhenSendFailed, setSendLatencyFaultEnable, setSendMessageWithVIPChannel, setSendMsgTimeout, viewMessage, viewMessage

从类继承的方法 org.apache.rocketmq.client.ClientConfig

buildMQClientId, changeInstanceNameToPID, cloneClientConfig, getAccessChannel, getClientCallbackExecutorThreads, getClientIP, getHeartbeatBrokerInterval, getInstanceName, getLanguage, getNamespace, getNamesrvAddr, getPersistConsumerOffsetInterval, getPollNameServerInterval, getPullTimeDelayMillsWhenException, getUnitName, isUnitMode, isUseTLS, isVipChannelEnabled, queuesWithNamespace, queueWithNamespace, resetClientConfig, setAccessChannel, setClientCallbackExecutorThreads, setClientIP, setHeartbeatBrokerInterval, setInstanceName, setLanguage, setNamespace, setNamesrvAddr, setPersistConsumerOffsetInterval, setPollNameServerInterval, setPullTimeDelayMillsWhenException, setUnitMode, setUnitName, setUseTLS, setVipChannelEnabled, toString, withNamespace, withNamespace, withoutNamespace, withoutNamespace

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

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

字段详细资料

log

private final org.apache.rocketmq.logging.InternalLogger log

enableMsgTrace

private boolean enableMsgTrace

Switch flag instance for message trace.

customizedTraceTopic

private String customizedTraceTopic

enableAcl

private boolean enableAcl

accessKey

private String accessKey

The property of "access-key".

secretKey

private String secretKey

The property of "secret-key".

构造器详细资料

RocketMQTransactionProducer

public RocketMQTransactionProducer()

RocketMQTransactionProducer

public RocketMQTransactionProducer(String producerGroup)

RocketMQTransactionProducer

public RocketMQTransactionProducer(String namespace,
                                   String producerGroup)

RocketMQTransactionProducer

public RocketMQTransactionProducer(String producerGroup,
                                   org.apache.rocketmq.remoting.RPCHook rpcHook)

RocketMQTransactionProducer

public RocketMQTransactionProducer(String namespace,
                                   String producerGroup,
                                   org.apache.rocketmq.remoting.RPCHook rpcHook)

RocketMQTransactionProducer

public RocketMQTransactionProducer(String namespace,
                                   String producerGroup,
                                   org.apache.rocketmq.remoting.RPCHook rpcHook,
                                   boolean enableMsgTrace,
                                   String customizedTraceTopic)

方法详细资料

isEnableMsgTrace

public boolean isEnableMsgTrace()

setEnableMsgTrace

public void setEnableMsgTrace(boolean enableMsgTrace)

getCustomizedTraceTopic

public String getCustomizedTraceTopic()

setCustomizedTraceTopic

public void setCustomizedTraceTopic(String customizedTraceTopic)

isEnableAcl

public boolean isEnableAcl()

setEnableAcl

public void setEnableAcl(boolean enableAcl)

getAccessKey

public String getAccessKey()

setAccessKey

public void setAccessKey(String accessKey)

getSecretKey

public String getSecretKey()

setSecretKey

public void setSecretKey(String secretKey)

initialize

public void initialize()
                throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

uninitialize

public void uninitialize()
                  throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

registerHooks

private void registerHooks()
                    throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException

registerTraceHook

private void registerTraceHook()
                        throws org.apache.rocketmq.client.exception.MQClientException

抛出:

org.apache.rocketmq.client.exception.MQClientException