/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit/JobService/Configuration/InstanceJobServiceSettings.cs
41 строка
1 KB
Chris Patterson
Fixed a race condition in the job service where a job could be started while the job service is stopping, producing a fault that retries the job on another instance when available.
22 апр 2025, 18:11
22 апр 2025, 18:11
0fbca78
Код
Авторство
О чём код?
#nullable enable namespace MassTransit.Configuration { using System; using JobService; using Microsoft.Extensions.Options; public class InstanceJobServiceSettings : JobServiceSettings { readonly JobConsumerOptions _options; public InstanceJobServiceSettings(IOptions<JobConsumerOptions> options) : this(options.Value) { } public InstanceJobServiceSettings(JobConsumerOptions options) { _options = options; JobService = new JobService(this); } public TimeSpan HeartbeatInterval => _options.HeartbeatInterval; public TimeSpan RejectedJobDelay => _options.RejectedJobDelay; public Uri? InstanceAddress { get; set; } public IReceiveEndpointConfigurator? InstanceEndpointConfigurator { get; set; } public IJobService JobService { get; } public void ApplyConfiguration<T>(T configurator) where T : IReceiveEndpointConfigurator { InstanceEndpointConfigurator = configurator; InstanceAddress = configurator.InputAddress; } } }