问题: 用DefaultMQProducer的send( Message, S endCallback) 消息发送成功调用了onsucces,但是发送失败没有调用onException,也没有被catch到,哪位能给指导下
DefaultMQProducer的send(Message, S endCallback)方法用于将消息发送到一个或多个MQ Broker中。当消息发送成功时,endCallback回调将被调用,而发送失败时,onException回调将被调用,但是可能会被忽略。
如果发送失败时没有调用onException回调,可能是因为消息发送失败时没有触发异常处理程序。可以通过检查DefaultMQProducer的异常处理程序来确定是否有异常被捕获并处理。
另外,如果发送失败时没有调用onException回调,可能是因为消息发送失败时没有被捕获到。可以通过检查DefaultMQProducer的日志来确定是否有异常被捕获并处理。
总之,如果发送失败时没有调用onException回调,可能是因为消息发送失败时没有触发异常处理程序,或者没有被捕获到。通过检查DefaultMQProducer的异常处理程序和日志,可以找到并解决问题。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/