/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/Transports/MassTransit.EventHubIntegration/EventHubIntegration/SharedConnectionContext.cs
28 строк
778 B
denys.kozhevnikov
Concurrency Improvements for Riders
26 дек 2022, 17:01
26 дек 2022, 17:01
1b2eeb2
Код
Авторство
О чём код?
namespace MassTransit.EventHubIntegration { using System.Threading; using Azure.Messaging.EventHubs.Producer; using MassTransit.Middleware; public class SharedConnectionContext : ProxyPipeContext, ConnectionContext { readonly ConnectionContext _context; public SharedConnectionContext(ConnectionContext context, CancellationToken cancellationToken) : base(context) { _context = context; CancellationToken = cancellationToken; } public override CancellationToken CancellationToken { get; } public EventHubProducerClient CreateEventHubClient(string eventHubName) { return _context.CreateEventHubClient(eventHubName); } } }