From 9bfe7d474a4ff24ccd0fe4a4737efe2e1ae1c3ab Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Sat, 9 Jan 2021 12:51:00 +0100
Subject: [PATCH] Fix queue worker workflow selector predicate

---
 .../Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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);
         }