公共交通所有故障消息由一名故障消费者处理

Question

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

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

Answer 1

为什么不消费Fault呢？

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

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