SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Update Azure Service Bus activities with output properties

Browse source
This commit is contained in:
Sipke Schoorstra 2021-06-07 20:26:47 +02:00
parent ba3881ae45
commit 79fa07dc98
2 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusMessageReceived/AzureServiceBusQueueMessageReceived.cs
View file

@ -25,6 +25,9 @@ namespace Elsa.Activities.AzureServiceBus
[ActivityInput]
public Type MessageType { get; set; } = default!;
[ActivityOutput]
public object? ReceivedMessage { get; set; }
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context) => context.WorkflowExecutionContext.IsFirstPass ? ExecuteInternal(context) : Suspend();
protected override IActivityExecutionResult OnResume(ActivityExecutionContext context) => ExecuteInternal(context);
@ -34,6 +37,7 @@ namespace Elsa.Activities.AzureServiceBus
var message = (MessageModel) context.Input!;
var model = message.ReadBody(MessageType, _serializer);
ReceivedMessage = model;
return Done(model);
}
}

4
src/activities/Elsa.Activities.AzureServiceBus/Activities/AzureServiceBusTopicMessageReceived/AzureServiceBusTopicMessageReceived.cs
View file

@ -30,6 +30,9 @@ namespace Elsa.Activities.AzureServiceBus
[ActivityInput]
public Type MessageType { get; set; } = default!;
[ActivityOutput]
public object? ReceivedMessage { get; set; }
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context) => context.WorkflowExecutionContext.IsFirstPass ? ExecuteInternal(context) : Suspend();
protected override IActivityExecutionResult OnResume(ActivityExecutionContext context) => ExecuteInternal(context);
@ -39,6 +42,7 @@ namespace Elsa.Activities.AzureServiceBus
var message = (MessageModel) context.Input!;
var model = message.ReadBody(MessageType, _serializer);
ReceivedMessage = model;
return Done(model);
}
}