有什么方法可以检查消息是否已发布？

Question

我需要使用 Java 检查 RabbitMQ 队列中的消息。我已经阅读了RabbitMQ 的标准 Java API 文档 ，但似乎那里没有描述标准方法。我也提到过这个但没有找到任何标准方法。

我试图通过此实现的目标可以概括为：

1. 我的应用程序会将消息发布到fanout 交换中。

2. 现在在这里，我想获取我的应用程序已发布的消息的内容，或者确认消息是否已发布到正确的交换中。

这如何使用 Java 完成？

Answer 1

使用发布者确认，将消息本身添加到参数中CorrelationData，然后当您使用 Ack 获得回调时，您可以访问该消息。请参阅文档。