/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Transformation/ReplaceMessageFactory.cs
19 строк
605 B
Chris Patterson
Integration of all external packages into MassTransit, split out into Abstractions, Middleware, and the core MassTransit assembly.
22 янв 2022, 18:24
22 янв 2022, 18:24
b5b4f50
Код
Авторство
О чём код?
namespace MassTransit.Transformation { using System; using Initializers; public class ReplaceMessageFactory<TMessage> : IMessageFactory<TMessage> where TMessage : class { public InitializeContext<TMessage> Create(InitializeContext context) { if (context.TryGetPayload(out TransformContext<TMessage> transformContext) && transformContext.HasInput) return context.CreateMessageContext(transformContext.Input); throw new InvalidOperationException("The original message context was not available."); } } }