src/MassTransit/Configuration/JobConsumerOptions.cs - develop - vshmidt/masstransit

src/MassTransit/Configuration/JobConsumerOptions.cs

61 строка2 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:110fbca78

namespace MassTransit
{
    using System;
    using System.Collections.Generic;
    using Configuration;


    public class JobConsumerOptions :
        IOptions,
        ISpecification
    {
        public JobConsumerOptions()
        {
            HeartbeatInterval = TimeSpan.FromMinutes(1);
            RejectedJobDelay = TimeSpan.FromSeconds(3);
        }

        public TimeSpan HeartbeatInterval { get; set; }
        public TimeSpan RejectedJobDelay { get; set; }

        IEnumerable<ValidationResult> ISpecification.Validate()
        {
            if (HeartbeatInterval <= TimeSpan.Zero)
                yield return this.Failure("JobConsumerOptions", "HeartbeatInterval", "Must be > 0");
            if (RejectedJobDelay <= TimeSpan.Zero)
                yield return this.Failure("JobConsumerOptions", "RejectedJobDelay", "Must be > 0");
        }

        public JobConsumerOptions SetHeartbeatInterval(int? d = null, int? h = null, int? m = null, int? s = null, int? ms = null)
        {
            var value = new TimeSpan(d ?? 0, h ?? 0, m ?? 0, s ?? 0, ms ?? 0);

            HeartbeatInterval = value;

            return this;
        }

        public JobConsumerOptions SetHeartbeatInterval(TimeSpan interval)
        {
            HeartbeatInterval = interval;

            return this;
        }

        public JobConsumerOptions SetRejectedJobDelay(int? d = null, int? h = null, int? m = null, int? s = null, int? ms = null)
        {
            var value = new TimeSpan(d ?? 0, h ?? 0, m ?? 0, s ?? 0, ms ?? 0);

            RejectedJobDelay = value;

            return this;
        }

        public JobConsumerOptions SetRejectedJobDelay(TimeSpan interval)
        {
            RejectedJobDelay = interval;

            return this;
        }
    }
}