RocketMQ源码解析-Producer消息发送

首先以默认的异步消息发送模式做为例子。DefaultMQProducer中的send()方法会直接调用DefaultMQProducerImpl的send()方法,在DefaultMQProducerImpl会直接调用sendDefaultImpl()方法。html   public void send(Message msg, SendCallback sendCallback) throws
相关文章
相关标签/搜索