所有故障消息的公共交通一个故障消费者

Question

如何让一个通用消费者处理所有故障消息？

我是否需要为我的每条故障消息注册故障消费者？

Answer 1

为什么不消费Fault？

public class WantAllFaultsGimmeThem : IConsumer<Fault>
{
    public async Task Consume(ConsumeContext<Fault> context)
    {
        // whatever you want to do here
    }
}

唯一的问题是 Message 不是这个接口的一部分，因此它甚至不会被反序列化。所以您将无法访问消息，只能访问消息 ID。

所有故障消息的公共交通一个故障消费者

Masstransit one fault consumer for all fault message

masstransit