From 0351f2360e9fc40d25dbfc7a22afd24e691df5ce Mon Sep 17 00:00:00 2001 From: Sipke Schoorstra Date: Tue, 22 Jun 2021 20:11:30 +0200 Subject: [PATCH] Update Azure Worker to not throw when trying to complete an already closed client --- .../Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs index 2bd37c2ac..6a45bbdab 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs @@ -102,10 +102,8 @@ namespace Elsa.Activities.AzureServiceBus.Services _logger.LogDebug("Message received with ID {MessageId}", message.MessageId); await TriggerWorkflowsAsync(message, CancellationToken.None); - if (ReceiverClient.IsClosedOrClosing) - throw new WorkflowException("Can't handle message with closed receiver"); - - await ReceiverClient.CompleteAsync(message.SystemProperties.LockToken); + if (!ReceiverClient.IsClosedOrClosing) + await ReceiverClient.CompleteAsync(message.SystemProperties.LockToken); } } } \ No newline at end of file