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

Run workflows directly from Azure queue

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-10 17:08:56 +01:00
parent 49d4e5bb36
commit 67cfbb6c1a
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/activities/Elsa.Activities.AzureServiceBus/Services/QueueWorker.cs
View file

@ -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);