/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Testing/Implementations/BusTestSendObserver.cs
45 строк
1 KB
Chris Patterson
Fixed #3754 - Test observers to properly clear inactivity when no activity of that type is performed.
18 окт 2022, 17:25
18 окт 2022, 17:25
53f1539
Код
Авторство
О чём код?
namespace MassTransit.Testing.Implementations { using System; using System.Threading; using System.Threading.Tasks; public class BusTestSendObserver : InactivityTestObserver, ISendObserver { readonly SentMessageList _messages; public BusTestSendObserver(TimeSpan timeout, TimeSpan inactivityTimout, CancellationToken testCompleted = default) { _messages = new SentMessageList(timeout, testCompleted); StartTimer(inactivityTimout); } public ISentMessageList Messages => _messages; public Task PreSend<T>(SendContext<T> context) where T : class { return RestartTimer(); } public Task PostSend<T>(SendContext<T> context) where T : class { _messages.Add(context); return RestartTimer(false); } public Task SendFault<T>(SendContext<T> context, Exception exception) where T : class { _messages.Add(context, exception); return RestartTimer(false); } } }