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

Class AsyncArrayDispatcher

java.lang.Object

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

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

public class AsyncArrayDispatcher
extends AsyncDispatcher

Created by alvin on 16-8-25.

Constructor Summary

Constructors

Constructor and Description
AsyncArrayDispatcher(Properties properties)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	append(Object ctx) 往数据传输模块中添加信息，
void	flush() 强制调用写操作
void	registerShutDownHook()
void	start(AsyncAppender appender, String workName) 初始化异步传输数据模块

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

Method Detail

start

public void start(AsyncAppender appender,
         String workName)

Description copied from class: AsyncDispatcher

初始化异步传输数据模块

Specified by:

start in class AsyncDispatcher

Parameters:

appender - 实际的传输模块

workName - 传输模块工作线程名称

append

public boolean append(Object ctx)

Description copied from class: AsyncDispatcher

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

Specified by:

append in class AsyncDispatcher

Parameters:

ctx - 数据信息

Returns:

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

flush

public void flush()
           throws IOException

Description copied from class: AsyncDispatcher

强制调用写操作

Specified by:

flush in class AsyncDispatcher

Throws:

IOException

registerShutDownHook

public void registerShutDownHook()

Specified by:

registerShutDownHook in class AsyncDispatcher