mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
Co-authored-by: zhangjidi <zhangjidi@cmss.chinamobile.com>
This commit is contained in:
@@ -158,22 +158,7 @@ public class DefaultMQProducer extends ClientConfig implements MQProducer {
|
||||
*/
|
||||
public DefaultMQProducer(final String producerGroup, RPCHook rpcHook, boolean enableMsgTrace,
|
||||
final String customizedTraceTopic) {
|
||||
this.producerGroup = producerGroup;
|
||||
defaultMQProducerImpl = new DefaultMQProducerImpl(this, rpcHook);
|
||||
//if client open the message trace feature
|
||||
if (enableMsgTrace) {
|
||||
try {
|
||||
AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(producerGroup, TraceDispatcher.Type.PRODUCE, customizedTraceTopic, rpcHook);
|
||||
dispatcher.setHostProducer(this.defaultMQProducerImpl);
|
||||
traceDispatcher = dispatcher;
|
||||
this.defaultMQProducerImpl.registerSendMessageHook(
|
||||
new SendMessageTraceHookImpl(traceDispatcher));
|
||||
this.defaultMQProducerImpl.registerEndTransactionHook(
|
||||
new EndTransactionTraceHookImpl(traceDispatcher));
|
||||
} catch (Throwable e) {
|
||||
log.error("system mqtrace hook init failed ,maybe can't send msg trace data");
|
||||
}
|
||||
}
|
||||
this(null, producerGroup, rpcHook, enableMsgTrace, customizedTraceTopic);
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -251,9 +236,9 @@ public class DefaultMQProducer extends ClientConfig implements MQProducer {
|
||||
if (enableMsgTrace) {
|
||||
try {
|
||||
AsyncTraceDispatcher dispatcher = new AsyncTraceDispatcher(producerGroup, TraceDispatcher.Type.PRODUCE, customizedTraceTopic, rpcHook);
|
||||
dispatcher.setHostProducer(this.getDefaultMQProducerImpl());
|
||||
dispatcher.setHostProducer(this.defaultMQProducerImpl);
|
||||
traceDispatcher = dispatcher;
|
||||
this.getDefaultMQProducerImpl().registerSendMessageHook(
|
||||
this.defaultMQProducerImpl.registerSendMessageHook(
|
||||
new SendMessageTraceHookImpl(traceDispatcher));
|
||||
this.defaultMQProducerImpl.registerEndTransactionHook(
|
||||
new EndTransactionTraceHookImpl(traceDispatcher));
|
||||
|
||||
Reference in New Issue
Block a user