是否可以在MassTransit中从错误队列中读取和删除消息？

Question

我们使用的是.Net核心/RabbitMQ/MassTransit，我有一个工作良好的ConsumerOrderCreatedEvent。

我希望有一个错误恢复机制，在该机制中，在应用程序启动时，我希望读取并删除错误队列中的消息。

是否可以在MassTransit中读取并删除错误队列中的消息？

Answer 1

您可以在错误队列上创建接收端点，它将读取与任何其他接收端点相同的消息。您需要一个能够读取消息格式并使用该错误消息(很可能与最初所做的操作不同)的使用者。

请注意，接收端点上的任何错误都将被移动到input-queue_error_error__，以此类推。

另一种选择是在RabbitMQ服务器上设置一个铲子来移动消息，但是要小心不要永远移动它们，因为可能存在将消息移动到错误队列的合法原因。但是，如果这与资源中断有关，并且再次重新处理这些消息是有意义的，请使用铲子将它们移回主队列。