
@Deprecated public class AsyncTraceDispatcher extends Object implements AsyncDispatcher
| Constructor and Description |
|---|
AsyncTraceDispatcher(Properties properties)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
append(Object ctx)
Deprecated.
队列满时直接丢弃数据,不阻塞业务线程,返回日志是否被接受
|
void |
flush()
Deprecated.
强制调用写操作
|
void |
registerShutdownHook()
Deprecated.
|
void |
removeShutDownHook()
Deprecated.
|
void |
shutdown()
Deprecated.
关闭轨迹Hook
|
int |
size()
Deprecated.
|
void |
start(String workerName)
Deprecated.
初始化异步传输数据模块
|
public AsyncTraceDispatcher(Properties properties) throws com.alibaba.rocketmq.client.exception.MQClientException
com.alibaba.rocketmq.client.exception.MQClientExceptionpublic void start(String workerName)
AsyncDispatcherstart in interface AsyncDispatcherworkerName - 传输模块工作线程名称public int size()
public boolean append(Object ctx)
append in interface AsyncDispatcherctx - 数据信息public void flush()
throws IOException
AsyncDispatcherflush in interface AsyncDispatcherIOExceptionpublic void shutdown()
AsyncDispatchershutdown in interface AsyncDispatcherpublic void registerShutdownHook()
public void removeShutDownHook()
Copyright © 2012–2018. All rights reserved.