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

Fix Azure Service Bus queue worker

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-15 14:56:31 +01:00
parent 84b5d64719
commit 7d576a7ddc
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -42,7 +42,7 @@ namespace Elsa.Activities.AzureServiceBus.Services
var workflowRunner = scope.ServiceProvider.GetRequiredService<IWorkflowRunner>();
await workflowRunner.TriggerWorkflowsAsync<MessageReceivedTrigger>(
x => x.QueueName == _messageReceiver.Path && (string.Equals(x.CorrelationId, message.CorrelationId)),
x => x.QueueName == _messageReceiver.Path && (x.CorrelationId == null || string.Equals(x.CorrelationId, message.CorrelationId)),
message,
message.CorrelationId,
cancellationToken: cancellationToken);