diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs index 9eeac8426..a2802bf82 100644 --- a/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs +++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/WorkerBase.cs @@ -97,7 +97,7 @@ namespace Elsa.Activities.AzureServiceBus.Services private async Task OnMessageReceived(Message message, CancellationToken cancellationToken) { _logger.LogDebug("Message received with ID {MessageId}", message.MessageId); - await TriggerWorkflowsAsync(message, cancellationToken); + await TriggerWorkflowsAsync(message, CancellationToken.None); await ReceiverClient.CompleteAsync(message.SystemProperties.LockToken); } }