/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Middleware/ScopeCompensateFilter.cs
31 строка
981 B
denys.kozhevnikov
Cleanup using
25 янв 2023, 22:00
25 янв 2023, 22:00
15c3b8b
Код
Авторство
О чём код?
namespace MassTransit.Middleware { using System.Threading.Tasks; using DependencyInjection; public class ScopeCompensateFilter<TActivity, TLog> : IFilter<CompensateContext<TLog>> where TLog : class where TActivity : class, ICompensateActivity<TLog> { readonly ICompensateActivityScopeProvider<TActivity, TLog> _scopeProvider; public ScopeCompensateFilter(ICompensateActivityScopeProvider<TActivity, TLog> scopeProvider) { _scopeProvider = scopeProvider; } public async Task Send(CompensateContext<TLog> context, IPipe<CompensateContext<TLog>> next) { await using ICompensateScopeContext<TLog> scope = await _scopeProvider.GetScope(context).ConfigureAwait(false); await next.Send(scope.Context).ConfigureAwait(false); } public void Probe(ProbeContext context) { context.CreateFilterScope("scope"); } } }