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

类 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.

构造器概要

构造器

构造器和说明
AsyncArrayDispatcher(Properties properties)

方法概要

方法

限定符和类型	方法和说明
boolean	append(Object ctx) 往数据传输模块中添加信息，
void	flush() 强制调用写操作
void	registerShutDownHook()
void	start(AsyncAppender appender, String workName) 初始化异步传输数据模块

从类继承的方法 java.lang.Object

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

构造器详细资料

AsyncArrayDispatcher

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

抛出:

com.alibaba.rocketmq.client.exception.MQClientException

方法详细资料

start

public void start(AsyncAppender appender,
         String workName)

从类复制的说明: AsyncDispatcher

初始化异步传输数据模块

指定者:

start 在类中 AsyncDispatcher

参数:

appender - 实际的传输模块

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

append

public boolean append(Object ctx)

从类复制的说明: AsyncDispatcher

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

指定者:

append 在类中 AsyncDispatcher

参数:

ctx - 数据信息

返回:

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

flush

public void flush()
           throws IOException

从类复制的说明: AsyncDispatcher

强制调用写操作

指定者:

flush 在类中 AsyncDispatcher

抛出:

IOException

registerShutDownHook

public void registerShutDownHook()

指定者:

registerShutDownHook 在类中 AsyncDispatcher