com.alibaba.ons.open.trace.core.dispatch.impl

Class InnerTraceProducer

java.lang.Object

com.alibaba.ons.open.trace.core.dispatch.impl.InnerTraceProducer

public class InnerTraceProducer
extends Object

Author:

MQDevelopers

Constructor Summary

Constructors

Constructor and Description
InnerTraceProducer(Properties properties, NameServerAddressSetter nameserverAddressSetter, com.alibaba.rocketmq.remoting.RPCHook rpcHook)

Method Summary

Modifier and Type	Method and Description
boolean	append(OnsTraceContext ctx)
static InnerTraceProducer	getTraceDispatcherProducer(Properties properties, NameServerAddressSetter nameserverAddressSetter, com.alibaba.rocketmq.remoting.RPCHook rpcHook)
static InnerTraceProducer	getTraceDispatcherProducer(Properties properties, SessionCredentialsProvider provider, NameServerAddressSetter nameserverAddressSetter)
static void	registerTraceDispatcher(String dispatcherId, InnerTraceProducer producer, boolean isSingleton)
static Set<String>	tryGetMessageQueueBrokerSet(com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl producer, String topic)
static Set<String>	tryGetMessageQueueBrokerSet(com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl consumer, String topic)
static void	unregisterTraceDispatcher(String dispatcherId, InnerTraceProducer producer, boolean isSingleton)

Methods inherited from class java.lang.Object

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

Constructor Detail

InnerTraceProducer

public InnerTraceProducer(Properties properties,
                          NameServerAddressSetter nameserverAddressSetter,
                          com.alibaba.rocketmq.remoting.RPCHook rpcHook)
                   throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

Method Detail

getTraceDispatcherProducer

public static InnerTraceProducer getTraceDispatcherProducer(Properties properties,
                                                            SessionCredentialsProvider provider,
                                                            NameServerAddressSetter nameserverAddressSetter)
                                                     throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

getTraceDispatcherProducer

public static InnerTraceProducer getTraceDispatcherProducer(Properties properties,
                                                            NameServerAddressSetter nameserverAddressSetter,
                                                            com.alibaba.rocketmq.remoting.RPCHook rpcHook)
                                                     throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

registerTraceDispatcher

public static void registerTraceDispatcher(String dispatcherId,
                                           InnerTraceProducer producer,
                                           boolean isSingleton)
                                    throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

unregisterTraceDispatcher

public static void unregisterTraceDispatcher(String dispatcherId,
                                             InnerTraceProducer producer,
                                             boolean isSingleton)

append

public boolean append(OnsTraceContext ctx)

tryGetMessageQueueBrokerSet

public static Set<String> tryGetMessageQueueBrokerSet(com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl producer,
                                                      String topic)

tryGetMessageQueueBrokerSet

public static Set<String> tryGetMessageQueueBrokerSet(com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl consumer,
                                                      String topic)