/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/DependencyInjection/Configuration/DelegateEndpointDefinition.cs
36 строк
1 KB
Chris Patterson
Job consumer instance endpoint can now be configured, updated RabbitMQ job consumer tests to use Quorum queues, including bus and instance endpoints.
21 янв 2025, 23:32
21 янв 2025, 23:32
8056fb9
Код
Авторство
О чём код?
namespace MassTransit.Configuration { public class DelegateEndpointDefinition : IEndpointDefinition { readonly IDefinition _definition; readonly IEndpointDefinition _endpointDefinition; readonly string _endpointName; public DelegateEndpointDefinition(string endpointName, IDefinition definition, IEndpointDefinition endpointDefinition) { _endpointName = endpointName; _definition = definition; _endpointDefinition = endpointDefinition; } public bool ConfigureConsumeTopology => _endpointDefinition?.ConfigureConsumeTopology ?? true; public string GetEndpointName(IEndpointNameFormatter formatter) { return _endpointName; } public void Configure<T>(T configurator, IRegistrationContext context) where T : IReceiveEndpointConfigurator { _endpointDefinition?.Configure(configurator, context); } public bool IsTemporary => _endpointDefinition?.IsTemporary ?? false; public int? PrefetchCount => _endpointDefinition?.PrefetchCount; public int? ConcurrentMessageLimit => _definition.ConcurrentMessageLimit ?? _endpointDefinition?.ConcurrentMessageLimit; } }