Fix issue with receive MassTransit message input variable use (#171)
This commit is contained in:
parent
cdb2c655f6
commit
28763c8b2f
|
|
@ -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<ActivityExecutionResult> 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());
|
||||
|
|
|
|||
Loading…
Reference in a new issue