/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/SagaStateMachine/Configuration/MessageCorrelationIdFaultEventCorrelationBuilder.cs
31 строка
1 KB
Chris Patterson
Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.
27 мар 2024, 02:43
27 мар 2024, 02:43
c17b1de
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using System; public partial class StateMachineInterfaceType<TInstance, TData> { public class MessageCorrelationIdFaultEventCorrelationBuilder : IEventCorrelationBuilder { readonly StateMachineInterfaceType<TInstance, Fault<TData>>.MassTransitEventCorrelationConfigurator _configurator; public MessageCorrelationIdFaultEventCorrelationBuilder(SagaStateMachine<TInstance> machine, Event<Fault<TData>> @event, IMessageCorrelationId<TData> messageCorrelationId) { var configurator = new StateMachineInterfaceType<TInstance, Fault<TData>>.MassTransitEventCorrelationConfigurator(machine, @event, null); configurator.CorrelateById(x => messageCorrelationId.TryGetCorrelationId(x.Message.Message, out var correlationId) ? correlationId : throw new ArgumentException($"The message {TypeCache<TData>.ShortName} did not have a correlationId")); _configurator = configurator; } public EventCorrelation Build() { return _configurator.Build(); } } } }