src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Defaults.cs - develop - vshmidt/masstransit

src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Defaults.cs

51 строка2 KB

Chris Patterson

Fixed Azure Service Bus exception stack trace exceeding header length issue

19 фев 2025, 22:23

19 фев 2025, 22:236ae1b2a

namespace MassTransit.AzureServiceBusTransport
{
    using System;
    using System.ComponentModel;
    using Azure.Messaging.ServiceBus.Administration;


    [EditorBrowsable(EditorBrowsableState.Never)]
    public static class Defaults
    {
        public static TimeSpan LockDuration { get; set; } = TimeSpan.FromMinutes(5);
        public static TimeSpan DefaultMessageTimeToLive { get; set; } = TimeSpan.FromDays(365 + 1);
        public static TimeSpan BasicMessageTimeToLive { get; set; } = TimeSpan.FromDays(14);

        public static TimeSpan AutoDeleteOnIdle { get; set; } = TimeSpan.FromDays(427);
        public static TimeSpan TemporaryAutoDeleteOnIdle { get; set; } = TimeSpan.FromMinutes(5);
        public static TimeSpan MaxAutoRenewDuration { get; set; } = TimeSpan.FromMinutes(5);

        public static TimeSpan? SessionIdleTimeout { get; set; } = null; // SDKs default is undefined - explicitly defined here for clarity
        public static TimeSpan ShutdownTimeout { get; set; } = TimeSpan.FromMilliseconds(100);

        public static int MaxConcurrentSessions { get; set; } = 8;
        public static int MaxConcurrentCallsPerSessions { get; set; } = 1;

        public const int MaxHeaderLengthBytes = 32767;
        public const int MaxHeaderLength = MaxHeaderLengthBytes / sizeof(char) - 1;

        public static CreateQueueOptions GetCreateQueueOptions(string queueName)
        {
            return new CreateQueueOptions(queueName)
            {
                AutoDeleteOnIdle = AutoDeleteOnIdle,
                DefaultMessageTimeToLive = DefaultMessageTimeToLive,
                EnableBatchedOperations = true,
                DeadLetteringOnMessageExpiration = true,
                LockDuration = LockDuration,
                MaxDeliveryCount = 5
            };
        }

        public static CreateTopicOptions GetCreateTopicOptions(string topicName)
        {
            return new CreateTopicOptions(topicName)
            {
                AutoDeleteOnIdle = AutoDeleteOnIdle,
                DefaultMessageTimeToLive = DefaultMessageTimeToLive,
                EnableBatchedOperations = true
            };
        }
    }
}