public interface AsyncDispatcher
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–2019. All rights reserved.