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

类 AsyncTraceAppender

java.lang.Object

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

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

public class AsyncTraceAppender
extends AsyncAppender

Created by alvin on 16-3-7.

构造器概要

构造器

构造器和说明
AsyncTraceAppender(Properties properties) 构造消息类型的轨迹数据发送器

方法概要

方法

限定符和类型	方法和说明
void	append(Object context) 往消息缓冲区编码轨迹数据
void	flush() 实际批量发送数据
void	sendTraceDataByMQ(Set<String> keySet, String data) 发送数据的接口

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

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

构造器详细资料

AsyncTraceAppender

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

构造消息类型的轨迹数据发送器

参数:

properties - 参数属性

抛出:

com.alibaba.rocketmq.client.exception.MQClientException

方法详细资料

append

public void append(Object context)

往消息缓冲区编码轨迹数据

指定者:

append 在类中 AsyncAppender

参数:

context -

flush

public void flush()

实际批量发送数据

指定者:

flush 在类中 AsyncAppender

sendTraceDataByMQ

public void sendTraceDataByMQ(Set<String> keySet,
                     String data)

发送数据的接口

参数:

keySet - 本批次包含的keyset

data - 本批次的轨迹数据