/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Middleware/RequestIdTeeFilter.cs
32 строки
833 B
Chris Patterson
Huge push towards optimization on startup, state machines, type discovery, caching, and the consume pipeline. Rebuilt the dispatch filter as a consume context filter for message type dispatch.
27 мар 2024, 02:43
27 мар 2024, 02:43
c17b1de
Код
Авторство
О чём код?
namespace MassTransit.Middleware { using System; public class RequestIdTeeFilter<TMessage> : TeeFilter<ConsumeContext<TMessage>>, IRequestIdTeeFilter<TMessage> where TMessage : class { readonly Lazy<IKeyPipeConnector<TMessage, Guid>> _keyConnections; public RequestIdTeeFilter() { _keyConnections = new Lazy<IKeyPipeConnector<TMessage, Guid>>(ConnectKeyFilter); } public ConnectHandle ConnectPipe(Guid key, IPipe<ConsumeContext<TMessage>> pipe) { return _keyConnections.Value.ConnectPipe(key, pipe); } RequestIdFilter<TMessage> ConnectKeyFilter() { var filter = new RequestIdFilter<TMessage>(); ConnectPipe(filter.ToPipe()); return filter; } } }