/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Middleware/InMemoryOutbox/InMemoryOutboxCompensateContext.cs
59 строк
2 KB
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.Middleware.InMemoryOutbox { using System; using System.Collections.Generic; using Context; public class InMemoryOutboxCompensateContext<TLog> : InMemoryOutboxCourierContextProxy, CompensateContext<TLog> where TLog : class { readonly CompensateContext<TLog> _context; public InMemoryOutboxCompensateContext(CompensateContext<TLog> context) : base(context) { _context = context; } CompensationResult CompensateContext.Compensated() { return _context.Compensated(); } CompensationResult CompensateContext.Compensated(object values) { return _context.Compensated(values); } CompensationResult CompensateContext.Compensated(IDictionary<string, object> variables) { return _context.Compensated(variables); } CompensationResult CompensateContext.Failed() { return _context.Failed(); } CompensationResult CompensateContext.Failed(Exception exception) { return _context.Failed(exception); } CompensationResult CompensateContext.Result { get => _context.Result; set => _context.Result = value; } TLog CompensateContext<TLog>.Log => _context.Log; CompensateActivityContext<TActivity, TLog> CompensateContext<TLog>.CreateActivityContext<TActivity>(TActivity activity) { return new HostCompensateActivityContext<TActivity, TLog>(activity, this); } } }