From 42bcb03b80e26e22cad060ba72533bf044ceaf0e Mon Sep 17 00:00:00 2001
From: Christoph Keller <32510127+ckeller81@users.noreply.github.com>
Date: Fri, 30 Jul 2021 09:17:18 +0200
Subject: [PATCH] Add WorkflowInput to CollectAndExecuteWorkflowsAsync() to
 receive the bus-message. (#1332) (#1333)

---
 .../Consumers/WorkflowConsumer.cs                        | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/activities/Elsa.Activities.MassTransit/Consumers/WorkflowConsumer.cs b/src/activities/Elsa.Activities.MassTransit/Consumers/WorkflowConsumer.cs
index e07fde7dd..7ad6e6d91 100644
--- a/src/activities/Elsa.Activities.MassTransit/Consumers/WorkflowConsumer.cs
+++ b/src/activities/Elsa.Activities.MassTransit/Consumers/WorkflowConsumer.cs
@@ -3,6 +3,7 @@ using System.Collections.Generic;
 using System.Threading.Tasks;
 using Elsa.Activities.MassTransit.Bookmarks;
 using Elsa.Activities.MassTransit.Consumers.MessageCorrelation;
+using Elsa.Models;
 using Elsa.Services;
 using Elsa.Services.Models;
 using MassTransit;
@@ -44,11 +45,15 @@ namespace Elsa.Activities.MassTransit.Consumers
                 MessageType = message.GetType().Name
             };
 
-            await _workflowLaunchpad.CollectAndExecuteWorkflowsAsync(new WorkflowsQuery(
+            var workflowQuery = new WorkflowsQuery(
                 nameof(ReceiveMassTransitMessage),
                 bookmark,
                 correlationId.ToString()
-            ));
+            );
+
+            var workflowInput = new WorkflowInput { Input = message };
+
+            await _workflowLaunchpad.CollectAndExecuteWorkflowsAsync(workflowQuery, workflowInput, context.CancellationToken);
         }
     }
 }
\ No newline at end of file