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

Class TraceProducerFactory

java.lang.Object

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

public class TraceProducerFactory
extends Object

Author:

MQDevelopers

Constructor Summary

Constructors

Constructor and Description
TraceProducerFactory()

Method Summary

Methods

Modifier and Type	Method and Description
static com.alibaba.rocketmq.client.producer.DefaultMQProducer	getTraceDispatcherProducer(Properties properties)
static com.alibaba.rocketmq.client.producer.DefaultMQProducer	getTraceDispatcherProducer(Properties properties, SessionCredentials sessionCredentials)
static void	registerTraceDispatcher(String dispatcherId)
static void	unregisterTraceDispatcher(String dispatcherId)

Methods inherited from class java.lang.Object

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

Constructor Detail

TraceProducerFactory

public TraceProducerFactory()

Method Detail

getTraceDispatcherProducer

public static com.alibaba.rocketmq.client.producer.DefaultMQProducer getTraceDispatcherProducer(Properties properties)

getTraceDispatcherProducer

public static com.alibaba.rocketmq.client.producer.DefaultMQProducer getTraceDispatcherProducer(Properties properties,
                                                                                SessionCredentials sessionCredentials)

registerTraceDispatcher

public static void registerTraceDispatcher(String dispatcherId)
                                    throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

unregisterTraceDispatcher

public static void unregisterTraceDispatcher(String dispatcherId)