mqtt - 消息未保留在 Apollo 服务器中

Question

我使用 fusesource 代码将 mqtt 消息发布到 Apollo 服务器时遇到问题。我用如下代码编写了消息发布者

connection.publish(topic, message.getBytes(),QoS.AT_LEAST_ONCE, true);

我还编写了订阅该主题的消息消费者。如果我先启动消费者，再启动发布者，消费者可以正确获取所有消息。但是，如果我先启动发布者再启动消费者，消费者将不会收到消息。另外，我进入了 Apollo 管理控制台，在队列中找不到任何消息。（请参阅随附的屏幕截图）。

我应该怎么做才能解决这个问题？我不能让我的消费者一直运行，我不想丢失来自发布者的任何消息。当消费者离线时，代理（Apollo）不应该保留所有消息吗？如果是，我怎么看不到？

这似乎是一个愚蠢的问题，但我对 MQTT 很陌生，我确实需要一些帮助。

Answer 1

我怀疑一旦没有生产者或消费者附加到该主题，该主题就会被自动删除。要禁用自动删除“功能”，请在 apollo.xml 的 virual_host 配置元素中添加以下 XML 元素：

<topic auto_delete_after="0"/>

未来版本的 apollo 将避免在持有保留消息APLO-319时删除该主题。

Answer 2

这似乎是一个错误，因为您已将消息标记为保留。但是，我不知道 Apollo 对一个主题的多个保留​​消息的表现如何。您可能想在他们的邮件列表中提出这个问题。