/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/SagaStateMachine/Configuration/MessageCorrelationIdEventCorrelationBuilder.cs
31 строка
1 KB
Chris Patterson
Massive file cleanup
27 мар 2024, 02:43
27 мар 2024, 02:43
2ac69e8
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using System; public partial class StateMachineInterfaceType<TInstance, TData> { public class MessageCorrelationIdEventCorrelationBuilder : IEventCorrelationBuilder { readonly MassTransitEventCorrelationConfigurator _configurator; public MessageCorrelationIdEventCorrelationBuilder(SagaStateMachine<TInstance> machine, Event<TData> @event, IMessageCorrelationId<TData> messageCorrelationId) { var configurator = new MassTransitEventCorrelationConfigurator(machine, @event, null); configurator.CorrelateById(x => messageCorrelationId.TryGetCorrelationId(x.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(); } } } }