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

Class AsyncArrayDispatcher

java.lang.Object

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

All Implemented Interfaces:

AsyncDispatcher

public class AsyncArrayDispatcher
extends Object
implements AsyncDispatcher

Author:

MQDevelopers

Constructor Summary

Constructors

Constructor and Description
AsyncArrayDispatcher(Properties properties)
AsyncArrayDispatcher(Properties properties, SessionCredentials sessionCredentials)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	append(Object ctx) 往数据传输模块中添加信息，
void	flush() 强制调用写操作
com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl	getHostConsumer()
com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl	getHostProducer()
void	registerShutDownHook()
void	removeShutdownHook()
void	setHostConsumer(com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl hostConsumer)
void	setHostProducer(com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl hostProducer)
void	shutdown() 关闭轨迹Hook
void	start() 初始化异步传输数据模块

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncArrayDispatcher

public AsyncArrayDispatcher(Properties properties)
                     throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

AsyncArrayDispatcher

public AsyncArrayDispatcher(Properties properties,
                    SessionCredentials sessionCredentials)
                     throws com.alibaba.rocketmq.client.exception.MQClientException

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

Method Detail

getHostProducer

public com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl getHostProducer()

setHostProducer

public void setHostProducer(com.alibaba.rocketmq.client.impl.producer.DefaultMQProducerImpl hostProducer)

getHostConsumer

public com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl getHostConsumer()

setHostConsumer

public void setHostConsumer(com.alibaba.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl hostConsumer)

start

public void start()
           throws com.alibaba.rocketmq.client.exception.MQClientException

Description copied from interface: AsyncDispatcher

初始化异步传输数据模块

Specified by:

start in interface AsyncDispatcher

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

append

public boolean append(Object ctx)

Description copied from interface: AsyncDispatcher

往数据传输模块中添加信息，

Specified by:

append in interface AsyncDispatcher

Parameters:

ctx - 数据信息

Returns:

返回true代表添加成功，返回false代表数据被抛弃

flush

public void flush()
           throws IOException

Description copied from interface: AsyncDispatcher

强制调用写操作

Specified by:

flush in interface AsyncDispatcher

Throws:

IOException

shutdown

public void shutdown()

Description copied from interface: AsyncDispatcher

关闭轨迹Hook

Specified by:

shutdown in interface AsyncDispatcher

registerShutDownHook

public void registerShutDownHook()

removeShutdownHook

public void removeShutdownHook()