是否可以从 MassTransit 的错误队列中读取和删除消息
Is it possible to read and remove messages from the error-queue in MassTransit
我们正在使用 .Net Core/RabbitMQ/MassTransit 并且我有一个运行良好的 Consumer[OrderCreatedEvent]。
我想要一个错误恢复机制，在应用程序启动时，我想在其中读取消息，然后从我的错误队列中删除消息。
是否可以从 MassTransit 的错误队列中读取并删除消息？
您可以在错误队列上创建一个接收端点，它会像任何其他接收端点一样读取消息。您需要一个可以读取消息格式并对错误消息执行某些操作的使用者（并且可能与最初所做的不同）。
请注意，该接收端点上的任何错误都将移至 input-queue_error_error，依此类推...
另一种选择是在 RabbitMQ 服务器上设置一个铲子来移动消息，但要注意不要永远移动它们，因为可能有正当理由将消息移动到错误队列。但如果它与资源中断有关并且再次重新处理这些消息是有意义的，请使用铲子将它们移回主队列。
我们正在使用 .Net Core/RabbitMQ/MassTransit 并且我有一个运行良好的 Consumer[OrderCreatedEvent]。
我想要一个错误恢复机制，在应用程序启动时，我想在其中读取消息，然后从我的错误队列中删除消息。
是否可以从 MassTransit 的错误队列中读取并删除消息？
您可以在错误队列上创建一个接收端点，它会像任何其他接收端点一样读取消息。您需要一个可以读取消息格式并对错误消息执行某些操作的使用者（并且可能与最初所做的不同）。
请注意，该接收端点上的任何错误都将移至 input-queue_error_error，依此类推...
另一种选择是在 RabbitMQ 服务器上设置一个铲子来移动消息，但要注意不要永远移动它们，因为可能有正当理由将消息移动到错误队列。但如果它与资源中断有关并且再次重新处理这些消息是有意义的，请使用铲子将它们移回主队列。