/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Middleware/ReceiveEndpointDependencyFilter.cs
32 строки
906 B
denys.kozhevnikov
Use ReceiveEndpointDependencyFilter to manage dependencies. Add new AddDependency override
31 мар 2023, 19:44
31 мар 2023, 19:44
b04a2dd
Код
Авторство
О чём код?
namespace MassTransit.Middleware { using System.Threading.Tasks; using Internals; using Transports; public class ReceiveEndpointDependencyFilter<TContext> : IFilter<TContext> where TContext : class, PipeContext { readonly ReceiveEndpointContext _context; public ReceiveEndpointDependencyFilter(ReceiveEndpointContext context) { _context = context; } public async Task Send(TContext context, IPipe<TContext> next) { await _context.DependenciesReady.OrCanceled(context.CancellationToken).ConfigureAwait(false); await next.Send(context).ConfigureAwait(false); } public void Probe(ProbeContext context) { var scope = context.CreateScope("receiveEndpointDependencies"); scope.Add("contextType", typeof(TContext).Name); } } }