From c4fc9bdfc1a89f4a7360f0d4ea88d3922dc0788a Mon Sep 17 00:00:00 2001 From: Sipke Schoorstra Date: Thu, 21 Jan 2021 19:30:28 +0100 Subject: [PATCH] Increase TTL --- .../Extensions/ElsaOptionsExtensions.cs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs b/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs index 9c41227da..0a933ce56 100644 --- a/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs +++ b/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs @@ -1,4 +1,5 @@ -using Elsa.Services; +using System; +using Elsa.Services; using Microsoft.Azure.ServiceBus.Primitives; using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.Logging; @@ -21,7 +22,7 @@ namespace Elsa.Rebus.AzureServiceBus context.Configurer .Logging(l => l.MicrosoftExtensionsLogging(loggerFactory)) - .Transport(t => t.UseAzureServiceBus(connectionString, queueName, tokenProvider)) + .Transport(t => t.UseAzureServiceBus(connectionString, queueName, tokenProvider).SetDefaultMessageTimeToLive(TimeSpan.FromMinutes(90))) // TODO: Make configurable. .Routing(r => r.TypeBased().Map(context.MessageTypeMap)) .Options(o => o.Apply(elsaOptions.ServiceBusOptions)); }