From 0a11cced56c0c5f61e4e7619f4cb5ede46dd38b7 Mon Sep 17 00:00:00 2001 From: Sipke Schoorstra Date: Thu, 21 Jan 2021 20:13:02 +0100 Subject: [PATCH] Set peek lock --- .../Extensions/ElsaOptionsExtensions.cs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs b/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs index 0a933ce56..3f72db5b4 100644 --- a/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs +++ b/src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs @@ -22,7 +22,7 @@ namespace Elsa.Rebus.AzureServiceBus context.Configurer .Logging(l => l.MicrosoftExtensionsLogging(loggerFactory)) - .Transport(t => t.UseAzureServiceBus(connectionString, queueName, tokenProvider).SetDefaultMessageTimeToLive(TimeSpan.FromMinutes(90))) // TODO: Make configurable. + .Transport(t => t.UseAzureServiceBus(connectionString, queueName, tokenProvider).SetMessagePeekLockDuration(TimeSpan.FromMinutes(5)).AutomaticallyRenewPeekLock()) .Routing(r => r.TypeBased().Map(context.MessageTypeMap)) .Options(o => o.Apply(elsaOptions.ServiceBusOptions)); }