/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/Consumers/Configuration/InstanceEndpointDefinition.cs
46 строк
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 { using System.Text; using NewIdFormatters; /// <summary> /// Instance-specific address for a service endpoint /// </summary> public class InstanceEndpointDefinition : IEndpointDefinition { public InstanceEndpointDefinition() { var instanceId = NewId.Next(); InstanceName = instanceId.ToString(ZBase32Formatter.LowerCase); } string InstanceName { get; } public bool IsTemporary => true; public int? PrefetchCount => default; public int? ConcurrentMessageLimit => default; public bool ConfigureConsumeTopology => true; public string GetEndpointName(IEndpointNameFormatter formatter) { var sb = new StringBuilder(InstanceName.Length + 9); sb.Append("Instance"); sb.Append('_'); sb.Append(InstanceName); return formatter.SanitizeName(sb.ToString()); } public void Configure<T>(T configurator, IRegistrationContext context) where T : IReceiveEndpointConfigurator { } } }