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

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

Constructor Summary

Constructors

Constructor and Description
AsyncTraceAppender(Properties properties) 构造消息类型的轨迹数据发送器

Method Summary

Methods

Modifier and Type	Method and Description
void	append(Object context) 往消息缓冲区编码轨迹数据
void	flush() 实际批量发送数据
void	sendTraceDataByMQ(Set<String> keySet, String data) 发送数据的接口

Methods inherited from class java.lang.Object

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

Constructor Detail

AsyncTraceAppender

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

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

Parameters:

properties - 参数属性

Throws:

com.alibaba.rocketmq.client.exception.MQClientException

Method Detail

append

public void append(Object context)

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

Specified by:

append in class AsyncAppender

Parameters:

context -

flush

public void flush()

实际批量发送数据

Specified by:

flush in class AsyncAppender

sendTraceDataByMQ

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

发送数据的接口

Parameters:

keySet - 本批次包含的keyset

data - 本批次的轨迹数据