目前,我有一个IErrorHandler实现,用于处理发送到Rebus错误队列的消息。然后,该处理程序将消息发布到saga,该saga将限制输出到松弛通知通道。不过,我认为可能有一种更简单的方法。我想让saga针对来自Rebus错误队列本身的消息实现IHandleMessages。可能吗?目前,我们启用了FleetManager进程,为了让我的自定义IErrorHandler工作,它必须使用FleetManager API选项将错误双重发布到错误队列和FleetManager。这允许调用我的IErrorHandler,这样我就可以发布一条自定义消息来开始slack saga,还可以向FleetManager提供它所需的数据。我的方法的问题是,Rebus错误队列只是随着我不再关心的数据而增长。所以我想我的问题是:有没有办法处理这些Rebus错误队列消息?或者更好的是,有没有一种简单的方法可以让这些错误队列消息在我知道我的故事中有它们之后消失?
注意:之所以要使用saga,而不是简单地使用FleetManager Slack web钩子,是因为要根据错误的自定义计数阈值进行通知,而不是针对遇到的每个错误。