DefaultMQProducer.send(message, timeout)的消息发送状态sendResult.getSendStatus()

使用DefaultMQProducer.send(message,timeout);能够经过sendResult.getSendStatus()查看发送到RocketMQ的信息是否发送成功,在使用以下代码进行发送信息,并对信息发送是否确认成功,若是不成功进行从新发送时:java public class MQProductor { private static final Logger
相关文章
相关标签/搜索