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