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

Question

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

Answer 1

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

正如您已经正确理解的那样，IErrorTracker 是 Rebus 用于跟踪失败的传递尝试的方式，因此它能够提供有关先前记录的异常的信息，如果消息是已处理。

不过它是 Rebus 的内部文件，因此不会以任何方式公开。不过，您可以通过几种不同的方式将其取出，例如通过 incoming pipeline step put it into the 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

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

Rebus firstlevel retry. Is there any way to get exception from previous delivery attempt?

rebus