时间戳

首页 > 解决方案 > 当 NServiceBus Recoverability 使用通知失败时发送消息

c# - 当 NServiceBus Recoverability 使用通知失败时发送消息

问题描述

当消息重试次数用完并移至错误队列时，如何发送消息（或发布事件）？

当一个请求进入我的系统时，我创建一个 Saga 来跟踪它。Saga 向处理程序发送命令以执行异步工作。如果处理程序失败，我想将该命令移动到错误队列（默认行为）并将消息发送到 Saga 以提醒最初请求工作的客户端。

我尝试自定义可恢复性行为以使用 Saga 作为错误队列，它将命令发回但不会将其放入错误队列：

recoverability.CustomPolicy((config, context) =>
{
    // invocation of default recoverability policy
    var action = DefaultRecoverabilityPolicy.Invoke(config, context);

    if (action is MoveToError)
    {
        return RecoverabilityAction.MoveToError("SagaEndpoint");
    }

    return action;
});

我尝试的另一件事是使用行为挂钩到管道，但似乎没有一种方法可以覆盖“移动到错误队列”步骤。我可以在 周围创建一个IIncomingLogicalMessageContext并尝试/捕获await next();，但这会触发每次重试，而不仅仅是最后一次重试。我也尝试了一个IOutgoingLogicalMessageContext，但是当消息移动到错误队列时不会调用它。如果我错过了什么，那可能是一个解决方案。

我也知道我可以在 Saga 中使用超时来猜测 Handler 何时失败。但如果失败很快，我宁愿不等待超时，或者如果工作花费的时间比预期的长，我宁愿冒着超时的风险。

我发现这个较旧的问题听起来像是在问同样的事情，但答案不完整，并且使用较旧的 EventHandler 通知而不是较新的基于任务的通知。如果有办法从通知回调中访问IMessageSession或访问IEndpointInstance，我认为这对我也有用。

标签： c#nservicebus

解决方案

没有一种“简单”的方法可以做到这一点，因为在发生可恢复性的那一刻，与传入消息相关的任何事务（每个传输都不同）都是有疑问的，所以你不能在范围内做任何其他事情在那一刻发生的事情。

启动端点后，您可以将其强制IEndpointInstance转换为IMessageSession（没有 Stop 方法之类的东西），然后将其分配给“错误队列通知程序”能够找到它的位置。然后，您对 执行的任何操作IMessageSession基本上都是一个单独的上下文，与传入消息的处理断开连接。

只需了解，如果由于队列的潜在问题而导致消息处理失败，则不会正确报告。这就是为什么大多数人会在这些回调中对报告/诊断服务进行某种调用。

推荐阅读