From 913241732a98cdfb36df4b9df85ff55c2b0177f3 Mon Sep 17 00:00:00 2001 From: Sipke Schoorstra Date: Mon, 21 Dec 2020 13:54:44 +0100 Subject: [PATCH] Fix locking in MessageSenderFactory --- .../Services/MessageSenderFactory.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/MessageSenderFactory.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/MessageSenderFactory.cs index ebfd37c49..d281a3b77 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Services/MessageSenderFactory.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/MessageSenderFactory.cs @@ -23,11 +23,11 @@ namespace Elsa.Activities.AzureServiceBus.Services public async Task GetSenderAsync(string queueName, CancellationToken cancellationToken) { + await _semaphore.WaitAsync(cancellationToken); + if (_senders.TryGetValue(queueName, out var messageSender)) return messageSender; - await _semaphore.WaitAsync(cancellationToken); - try { await _managementClient.EnsureQueueExistsAsync(queueName, cancellationToken);