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

类 AsyncTraceDispatcher

java.lang.Object

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

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

public class AsyncTraceDispatcher
extends AsyncDispatcher

异步提交消息轨迹等数据

构造器概要

构造器

构造器和说明
AsyncTraceDispatcher(Properties properties)

方法概要

方法

限定符和类型	方法和说明
boolean	append(Object ctx) 队列满时直接丢弃数据，不阻塞业务线程，返回日志是否被接受
void	flush() 强制调用写操作
int	size()
void	start(AsyncAppender appender, String workerName) 初始化异步传输数据模块

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

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

构造器详细资料

AsyncTraceDispatcher

public AsyncTraceDispatcher(Properties properties)

方法详细资料

start

public void start(AsyncAppender appender,
         String workerName)

从类复制的说明: AsyncDispatcher

初始化异步传输数据模块

指定者:

start 在类中 AsyncDispatcher

参数:

appender - 实际的传输模块

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

size

public int size()

append

public boolean append(Object ctx)

队列满时直接丢弃数据，不阻塞业务线程，返回日志是否被接受

指定者:

append 在类中 AsyncDispatcher

参数:

ctx - 数据信息

返回:

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

flush

public void flush()
           throws IOException

从类复制的说明: AsyncDispatcher

强制调用写操作

指定者:

flush 在类中 AsyncDispatcher

抛出:

IOException