NServiceBus 可恢复性失败时发送消息
Send Message when NServiceBus Recoverability fails
有没有办法在且仅当 Recoverability 执行的所有重试都失败时向 NServiceBus 发送消息?简而言之,我想将一条新消息发送到另一个队列(同时它被发送到错误队列)。我不确定是否或如何插入管道来执行此操作。
我有一个下面的行为,当我抛出一个特定的异常时,它通过向 NServiceBus 发送一个事件(绕过重试)来处理它,但是我有另一个用例,我想在重试后发送相同的事件也失败了。
class OperationFailedExceptionBehavior : Behavior<IIncomingLogicalMessageContext>
{
public override async Task Invoke(IIncomingLogicalMessageContext context, Func<Task> next)
{
try
{
await next().ConfigureAwait(false);
}
catch (OperationFailedException ex)
{
//since we're catching the exception, retries will no longer occur.
await context.Publish(new OperationFailedEvent(ex));
}
}
}
可能通知就是您要找的。您可以订阅错误通知,我认为这将为您提供实现上述要求所需的所有详细信息。
更多详情:https://docs.particular.net/nservicebus/recoverability/subscribing-to-error-notifications
有没有办法在且仅当 Recoverability 执行的所有重试都失败时向 NServiceBus 发送消息?简而言之,我想将一条新消息发送到另一个队列(同时它被发送到错误队列)。我不确定是否或如何插入管道来执行此操作。
我有一个下面的行为,当我抛出一个特定的异常时,它通过向 NServiceBus 发送一个事件(绕过重试)来处理它,但是我有另一个用例,我想在重试后发送相同的事件也失败了。
class OperationFailedExceptionBehavior : Behavior<IIncomingLogicalMessageContext>
{
public override async Task Invoke(IIncomingLogicalMessageContext context, Func<Task> next)
{
try
{
await next().ConfigureAwait(false);
}
catch (OperationFailedException ex)
{
//since we're catching the exception, retries will no longer occur.
await context.Publish(new OperationFailedEvent(ex));
}
}
}
可能通知就是您要找的。您可以订阅错误通知,我认为这将为您提供实现上述要求所需的所有详细信息。
更多详情:https://docs.particular.net/nservicebus/recoverability/subscribing-to-error-notifications