/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Sagas/Configuration/QuerySagaMessageConnector.cs
31 строка
1 KB
Chris Patterson
Massive file cleanup
27 мар 2024, 02:43
27 мар 2024, 02:43
2ac69e8
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using Middleware; public partial class SagaConnector<TSaga, TMessage> where TSaga : class, ISaga where TMessage : class { public class QuerySagaMessageConnector : SagaMessageConnector { readonly ISagaPolicy<TSaga, TMessage> _policy; readonly ISagaQueryFactory<TSaga, TMessage> _queryFactory; public QuerySagaMessageConnector(IFilter<SagaConsumeContext<TSaga, TMessage>> consumeFilter, ISagaPolicy<TSaga, TMessage> policy, ISagaQueryFactory<TSaga, TMessage> queryFactory) : base(consumeFilter) { _policy = policy; _queryFactory = queryFactory; } protected override void ConfigureMessagePipe(IPipeConfigurator<ConsumeContext<TMessage>> configurator, ISagaRepository<TSaga> repository, IPipe<SagaConsumeContext<TSaga, TMessage>> sagaPipe) { configurator.UseFilter(new QuerySagaFilter<TSaga, TMessage>(repository, _policy, _queryFactory, sagaPipe)); } } } }