MassTransit/RabbitMq 错误队列 - 如何删除消息？

Question

我有一个队列 {QueueName}。我定义了一个消费者和 faulted-messages 消费者如下：

                        cfg.ReceiveEndpoint
                        (
                            queueName: QueueName,
                            e =>
                            {
                                 e.UseMessageRetry(r => r.Immediate(2));

                                e.AutoDelete = false;
                                e.Durable = true;
                                e.Consumer(() => container.Resolve<My_Consumer>());
                                e.Consumer(() => container.Resolve<My_Fault_Consumer>());
                            }
                        );

当消费者耗尽其处理消息的尝试次数时，故障消息消费者将启动并通过记录错误来处理消息。我注意到创建了额外的队列，名为 {QueueName}_error。

My_Fault_Consumer 不确认故障消息消耗并且队列增长。

如何确认这些消息？

Answer 1

error队列是毒队列，或者invalid message channel

Fault<T> 消息的消费者不使用此队列。 Fault 消息与任何其他消息一样发布。如果您查看毒队列的内容，您将不会在其中看到任何 Fault 消息，因为它打算保留原始消息，而您的消费者未能使用这些消息。

这里的目的是让您能够查看这些消息并最终决定将它们移回原始队列以供 re-processing，或者只是评估这些消息的内容以进行故障排除。

MassTransit 不对该队列执行任何操作，也不会从那里删除消息。您可以自己从 UI 或使用管理 API 或您的经纪人..

MassTransit/RabbitMq 错误队列 - 如何删除消息？

MassTransit/RabbitMq Error queue - how to delete messages?

c#

masstransit

rabbitmq