/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Monitoring/Performance/PerformanceCounterBusObserver.cs
58 строк
1 KB
denys.kozhevnikov
Cleanup using
25 янв 2023, 22:00
25 янв 2023, 22:00
15c3b8b
Код
Авторство
О чём код?
namespace MassTransit.Monitoring.Performance { using System; using System.Threading.Tasks; public class PerformanceCounterBusObserver : IBusObserver { readonly ICounterFactory _factory; public PerformanceCounterBusObserver(ICounterFactory factory) { _factory = factory; } public void PostCreate(IBus bus) { bus.ConnectPublishObserver(new PerformanceCounterPublishObserver(_factory)); bus.ConnectSendObserver(new PerformanceCounterSendObserver(_factory)); bus.ConnectReceiveObserver(new PerformanceCounterReceiveObserver(_factory)); } public void CreateFaulted(Exception exception) { } public Task PreStart(IBus bus) { return Task.CompletedTask; } public Task PostStart(IBus bus, Task<BusReady> busReady) { return Task.CompletedTask; } public Task StartFaulted(IBus bus, Exception exception) { return Task.CompletedTask; } public Task PreStop(IBus bus) { return Task.CompletedTask; } public Task PostStop(IBus bus) { return Task.CompletedTask; } public Task StopFaulted(IBus bus, Exception exception) { return Task.CompletedTask; } } }