/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Topology/Configuration/SetRoutingKeyMessageSendTopology.cs
27 строк
778 B
Chris Patterson
Refactored RoutingKey send topology formatter into the main assembly (used by gRPC and RabbitMQ, also the Database Transport)
16 июл 2023, 15:43
16 июл 2023, 15:43
62a1596
Код
Авторство
О чём код?
namespace MassTransit.Configuration { using System; using Middleware; using Transports; public class SetRoutingKeyMessageSendTopology<TMessage> : IMessageSendTopology<TMessage> where TMessage : class { readonly IFilter<SendContext<TMessage>> _filter; public SetRoutingKeyMessageSendTopology(IMessageRoutingKeyFormatter<TMessage> routingKeyFormatter) { if (routingKeyFormatter == null) throw new ArgumentNullException(nameof(routingKeyFormatter)); _filter = new SetRoutingKeyFilter<TMessage>(routingKeyFormatter); } public void Apply(ITopologyPipeBuilder<SendContext<TMessage>> builder) { builder.AddFilter(_filter); } } }