Skip to content

Commit 4068c4b

Browse files
committed
FEAT: Adding config to topics
1 parent 54cb047 commit 4068c4b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/AzureServiceBusFlow/Hosts/ServiceBusConsumerHostedService.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,8 +30,8 @@ public Task StartAsync(CancellationToken cancellationToken)
3030
: _client.CreateProcessor(queueOrTopicName, subscriptionName, new ServiceBusProcessorOptions
3131
{
3232
MaxConcurrentCalls = 5,
33-
MaxAutoLockRenewalDuration = TimeSpan.FromMinutes(60),
34-
AutoCompleteMessages = false,
33+
MaxAutoLockRenewalDuration = TimeSpan.FromSeconds(azureServiceBusConfiguration.MaxAutoLockRenewalDurationInSeconds),
34+
AutoCompleteMessages = azureServiceBusConfiguration.ServiceBusReceiveMode == ServiceBusReceiveMode.PeekLock,
3535
ReceiveMode = azureServiceBusConfiguration.ServiceBusReceiveMode,
3636
Identifier = queueOrTopicName + " - " + subscriptionName,
3737
});

0 commit comments

Comments
 (0)