/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/Transports/MassTransit.EventHubIntegration/EventHubIntegration/SharedProcessorContext.cs
36 строк
1000 B
Chris Patterson
Fixed #6049 - avoid failure when reusing the client on a subsequent receive transport restart
25 июл 2025, 18:49
25 июл 2025, 18:49
9f46a6c
Код
Авторство
О чём код?
namespace MassTransit.EventHubIntegration { using System.Threading; using Azure.Messaging.EventHubs; using Logging; using MassTransit.Middleware; public class SharedProcessorContext : ProxyPipeContext, ProcessorContext { readonly ProcessorContext _context; public SharedProcessorContext(ProcessorContext context, CancellationToken cancellationToken) : base(context) { _context = context; CancellationToken = cancellationToken; } public override CancellationToken CancellationToken { get; } public ILogContext LogContext => _context.LogContext; public EventProcessorClient GetClient(ProcessorClientBuilderContext context) { return _context.GetClient(context); } public void ReleaseClient(ProcessorClientBuilderContext processorLockContext) { _context.ReleaseClient(processorLockContext); } } }