开发者社区 > 云原生 > 消息队列 > 正文

消息队列中mqtt方式中sampleClient.setCallback中无法调用messageArrived方法

在消息队列中,我使用官方提供的Demo,com.aliyun.openservice.ons.mqtt.demo,可以发送消息,但是在测试接收消息时始终无法收到消息,测试方法运行后只显示:subscribe....success,但是发送的消息都无法收到。在ones控制台查看订阅情况,显示无任何订阅者在线。
我感觉 在回调函数(sampleClient.setCallback(new MqttCallback() )中,方法messageArrived和deliveryComplete都没有执行

展开
收起
小区管家 2016-03-09 15:52:39 10700 0
2 条回答
写回答
取消 提交回答
  • 第一次订阅先sleep一会,然后再生产消息试试。

    2019-07-17 18:33:10
    赞同 展开评论 打赏
  • 我也遇到相同的问题,不过我检测了再发送的时候deliveryComplete可以被执行。但是messageArrived没有被执行。着意味着消息没有被接收到。 不过我用tcp方式去接受消息成功了!

    2019-07-17 18:33:10
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    企业互联网架构之消息队列 立即下载
    基于消息队列RocketMQ的大型分布式应用上云最佳实践 立即下载
    云原生消息队列Apache RocketMQ 立即下载