diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
index d13b61d4e..cb98547ac 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
@@ -42,7 +42,7 @@ namespace Elsa.Activities.AzureServiceBus.Services
             var workflowRunner = scope.ServiceProvider.GetRequiredService<IWorkflowRunner>();
 
             await workflowRunner.TriggerWorkflowsAsync<MessageReceivedTrigger>(
-                x => x.QueueName == _messageReceiver.Path && (string.Equals(x.CorrelationId, message.CorrelationId)),
+                x => x.QueueName == _messageReceiver.Path && (x.CorrelationId == null || string.Equals(x.CorrelationId, message.CorrelationId)),
                 message,
                 message.CorrelationId,
                 cancellationToken: cancellationToken);