From 28763c8b2fa2b335cccc75232b47118c2c6366a7 Mon Sep 17 00:00:00 2001 From: Peter Davis Date: Mon, 18 Nov 2019 17:33:35 +1030 Subject: [PATCH] Fix issue with receive MassTransit message input variable use (#171) --- .../Activities/ReceiveMassTransitMessage.cs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/activities/Elsa.Activities.MassTransit/Activities/ReceiveMassTransitMessage.cs b/src/activities/Elsa.Activities.MassTransit/Activities/ReceiveMassTransitMessage.cs index 5e9d5671b..7f0c3e766 100644 --- a/src/activities/Elsa.Activities.MassTransit/Activities/ReceiveMassTransitMessage.cs +++ b/src/activities/Elsa.Activities.MassTransit/Activities/ReceiveMassTransitMessage.cs @@ -32,7 +32,7 @@ namespace Elsa.Activities.MassTransit.Activities protected override bool OnCanExecute(WorkflowExecutionContext context) { - var messageTypeName = context.Workflow.Input[Constants.MessageTypeNameInputKey]; + var messageTypeName = context.Workflow.Input.GetVariable(Constants.MessageTypeNameInputKey); var messageInputType = System.Type.GetType(messageTypeName.ToString()); var messageType = MessageType; @@ -47,7 +47,7 @@ namespace Elsa.Activities.MassTransit.Activities protected override Task OnResumeAsync(WorkflowExecutionContext context, CancellationToken cancellationToken) { - var message = context.Workflow.Input[Constants.MessageInputKey]; + var message = context.Workflow.Input.GetVariable(Constants.MessageInputKey); context.SetLastResult(message); return Task.FromResult(Done());