public interface AsyncDispatcher
| Modifier and Type | Method and Description |
|---|---|
boolean |
append(Object ctx)
往数据传输模块中添加信息,
|
void |
flush()
强制调用写操作
|
void |
shutdown()
关闭轨迹Hook
|
void |
start()
初始化异步传输数据模块
|
void start()
throws com.alibaba.rocketmq.client.exception.MQClientException
com.alibaba.rocketmq.client.exception.MQClientExceptionboolean append(Object ctx)
ctx - 数据信息void flush()
throws IOException
IOExceptionvoid shutdown()
Copyright © 2012–2018. All rights reserved.