/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/SagaStateMachine/Configuration/StateMachineEventConnectorFactory.cs
32 строки
1 KB
Chris Patterson
Massive file cleanup
27 мар 2024, 02:43
27 мар 2024, 02:43
2ac69e8
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using System; using Middleware; public partial class StateMachineInterfaceType<TInstance, TData> { public class StateMachineEventConnectorFactory : ISagaConnectorFactory { readonly ISagaMessageConnector<TInstance> _connector; public StateMachineEventConnectorFactory(SagaStateMachine<TInstance> stateMachine, EventCorrelation<TInstance, TData> correlation) { var consumeFilter = new StateMachineSagaMessageFilter<TInstance, TData>(stateMachine, correlation.Event); _connector = new StateMachineSagaMessageConnector(consumeFilter, correlation.Policy, correlation.FilterFactory, correlation.MessageFilter, correlation.ConfigureConsumeTopology); } ISagaMessageConnector<T> ISagaConnectorFactory.CreateMessageConnector<T>() { if (_connector is ISagaMessageConnector<T> connector) return connector; throw new ArgumentException("The saga type did not match the connector type"); } } } }