From 7d576a7ddc97309731d49d6f671f7efb70f1e14e Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Fri, 15 Jan 2021 14:56:31 +0100
Subject: [PATCH] Fix Azure Service Bus queue worker

---
 .../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 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);