SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Increase TTL

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-21 19:30:28 +01:00
parent 25cf309cba
commit c4fc9bdfc1
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/servicebus/Elsa.Rebus.AzureServiceBus/Extensions/ElsaOptionsExtensions.cs
View file

@ -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));
}