拦截ActiveMQ设备ID

Question

当经纪人拥有一个发布者和订阅者（通过MQTT）时，持久没有消息。我在LevelDB和MySQL中进行了测试。在LevelDB中只是主题名称。也许配置是错误的，还是我需要另一个持久性？也许MQTT消息未写入消息存储？

我的任务是获取出版/订户ID的。我该怎么做，也许其中一些：

• 获得另一个持久性，这样的kahadb带有存档=真或高性能期刊？
• 配置了"正确"的持久性？
• 获取一些日志或经纪杂志？
• 编写插件并从RAM获取此数据？

版本5.9。

LevelDB配置：

 <persistenceAdapter>
  <LevelDB directory="${activemq.data}/leveldb"/>
 </persistenceAdapter>

现在，我试图在Kahadb获得日志档案？但是没有结果。存档文件夹空：

<persistenceAdapter>
  <kahaDB directory="${activemq.data}/kahadb" archiveDataLogs="true" directoryArchive="${activemq.data}/datalog"/>
 </persistenceAdapter>

谢谢。

Answer 1

我不是ActiveMQ方面的专家，但我认为这可能很难实现。使用ActiveMQ是您的困难要求还是可以更改产品？

如果ActiveMQ不是一个艰难的重新解释，则可能是使用功能齐全的MQTT代理，该代理明确允许进行诸如HiveMQ之类的消息拦截。借助插件系统，可以完全有可能拦截消息，提取物品并将其保存到选择的数据库（无论是SQL还是NOSQL）。您可以在此处找到一篇大图的博客文章。

可以在此处找到插件系统的文档。

请注意，由于我在Hivemq工作以来，我可能会有偏见。