Rebus 一级重试有什么办法可以从以前的交付尝试中获得异常吗？

问题描述

我知道，rebus 在 IErrorTraker (InMemErrorTracker) 中存储跨消息传递的错误。有什么方法可以将 IErrorTraker 注入处理程序或从以前的尝试中获取异常的其他方法吗？谢谢！

解决方法

是的，但您需要自己做一些工作。

正如您正确理解的那样，IErrorTracker 是 Rebus 用来跟踪失败的传递尝试的工具，因此它能够提供有关先前记录的异常的信息，如果消息正在处理，则给定 ID。

虽然它是 Rebus 内部的，所以它没有以任何方式暴露。不过，您可以通过几种不同的方式将其取出，例如通过将 incoming pipeline step 放入 incoming step context:

可以在此处看到执行此操作的方法（以粗略和简单的方式）：

Configure.With(activator)
    .Transport(t => (...))
    .Options(o => o.Decorate<IPipeline>(c =>
    {
        var pipeline = c.Get<IPipeline>();
        var errorTracker = c.Get<IErrorTracker>();
        var step = new ExposeErrorTrackerStep(errorTracker);

        return new PipelineStepConcatenator(pipeline)
            .OnReceive(step,PipelineAbsolutePosition.Front);
    }))
    .Start();

更复杂的版本会将丑陋的配置内容放入适当的扩展方法中：

public static void ExposeErrorTracker(this OptionsConfigurer configurer) =>
    configurer.Decorate<IPipeline>(c =>
    {
        var pipeline = c.Get<IPipeline>();
        var errorTracker = c.Get<IErrorTracker>();
        var step = new ExposeErrorTrackerStep(errorTracker);

        return new PipelineStepConcatenator(pipeline)
            .OnReceive(step,PipelineAbsolutePosition.Front);
    });

然后像这样使用它：

Configure.With(activator)
    .Transport(t => (...))
    .Options(o => o.ExposeErrorTracker())
    .Start();

最后，这里是步骤的实现：

[StepDocumentation("Makes Rebus' IErrorTracker available in the incoming step context.")]
class ExposeErrorTrackerStep : IIncomingStep
{
    readonly IErrorTracker _errorTracker;

    public ExposeErrorTrackerStep(IErrorTracker errorTracker) => _errorTracker = errorTracker;

    public Task Process(IncomingStepContext context,Func<Task> next)
    {
        context.Save(_errorTracker);
        return next();
    }
}

如您所见，它简单地将 IErrorTracker 隐藏在传入的步骤上下文中，您可以通过 IMessageContext 访问该上下文，该上下文会自动配置为注入处理程序。

完整的工作示例可以在这里看到：https://github.com/rebus-org/Rebus/blob/master/Rebus.Tests/Examples/ExposeInternalService_ErrorTracker.cs