diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
index 592166b08..7ef763648 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
             using var scope = _serviceProvider.CreateScope();
             var workflowQueue = scope.ServiceProvider.GetRequiredService<IWorkflowQueue>();
             await workflowQueue.EnqueueWorkflowsAsync<MessageReceivedTrigger>(
-                x => x.QueueName == _messageReceiver.Path && (string.IsNullOrWhiteSpace(x.CorrelationId) || x.CorrelationId == message.CorrelationId), 
+                x => x.QueueName == _messageReceiver.Path && (string.Equals(x.CorrelationId, message.CorrelationId)), 
                 message, message.CorrelationId, 
                 cancellationToken: cancellationToken);
         }