/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/DependencyInjection/Configuration/JobServiceEndpointDefinition.cs
45 строк
2 KB
Chris Patterson
Made the endpoint name configurable for the job service instance endpoint.
14 окт 2025, 23:11
14 окт 2025, 23:11
b617f57
Код
Авторство
О чём код?
#nullable enable namespace MassTransit.Configuration { using JobService; public class JobServiceEndpointDefinition : IEndpointDefinition<JobService> { readonly InstanceJobServiceSettings _jobServiceSettings; readonly IEndpointSettings<IEndpointDefinition<JobService>> _settings; string? _endpointName; public JobServiceEndpointDefinition(IEndpointSettings<IEndpointDefinition<JobService>> settings, InstanceJobServiceSettings jobServiceSettings) { _settings = settings; _jobServiceSettings = jobServiceSettings; } public bool IsTemporary => true; public int? PrefetchCount => _settings.PrefetchCount; public int? ConcurrentMessageLimit => _settings.ConcurrentMessageLimit; public bool ConfigureConsumeTopology => _settings.ConfigureConsumeTopology; public void Configure<T>(T configurator, IRegistrationContext? context) where T : IReceiveEndpointConfigurator { _jobServiceSettings.ApplyConfiguration(configurator); _settings.ConfigureEndpoint(configurator, context); } public string GetEndpointName(IEndpointNameFormatter formatter) { string FormatName() { return _settings.Name ?? "Instance"; } return _endpointName ??= string.IsNullOrWhiteSpace(_settings.InstanceId) ? formatter.SanitizeName(FormatName()) : formatter.SanitizeName(FormatName() + formatter.Separator + _settings.InstanceId); } } }