/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/SagaStateMachine/Configuration/RedeliverRequestStateMachineSpecification.cs
28 строк
863 B
Chris Patterson
Fixed #3807 - added ability to configure redelivery for completed/faulted events that arrive prior to the started event
02 ноя 2022, 20:42
02 ноя 2022, 20:42
7f3e87e
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using System; public class RedeliverRequestStateMachineSpecification : IRequestStateMachineMissingInstanceConfigurator { readonly Action<IMissingInstanceRedeliveryConfigurator> _configure; public RedeliverRequestStateMachineSpecification(Action<IMissingInstanceRedeliveryConfigurator> configure) { _configure = configure; } public IPipe<ConsumeContext<TMessage>> Apply<TInstance, TMessage>(IMissingInstanceConfigurator<TInstance, TMessage> configurator) where TInstance : SagaStateMachineInstance where TMessage : class { return configurator.Redeliver(r => { r.OnRedeliveryLimitReached(x => x.Fault()); _configure?.Invoke(r); }); } } }