From 67cfbb6c1addfd2ef6542098f79b436372dea609 Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Sun, 10 Jan 2021 17:08:56 +0100
Subject: [PATCH] Run workflows directly from Azure queue

---
 .../Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs b/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
index 7ef763648..7df605fa3 100644
--- a/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
+++ b/src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
@@ -38,10 +38,10 @@ namespace Elsa.Activities.AzureServiceBus.Services
 
         private async Task TriggerWorkflowsAsync(Message message, CancellationToken cancellationToken)
         {
-            _logger.LogDebug("Triggering workflow {MessageId}", message.MessageId);
             using var scope = _serviceProvider.CreateScope();
-            var workflowQueue = scope.ServiceProvider.GetRequiredService<IWorkflowQueue>();
-            await workflowQueue.EnqueueWorkflowsAsync<MessageReceivedTrigger>(
+            var workflowRunner = scope.ServiceProvider.GetRequiredService<IWorkflowRunner>();
+            
+            await workflowRunner.TriggerWorkflowsAsync<MessageReceivedTrigger>(
                 x => x.QueueName == _messageReceiver.Path && (string.Equals(x.CorrelationId, message.CorrelationId)), 
                 message, message.CorrelationId, 
                 cancellationToken: cancellationToken);