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

Fix queue worker workflow selector predicate

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-09 12:51:00 +01:00
parent f98d31842e
commit 9bfe7d474a
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
using var scope = _serviceProvider.CreateScope();
var workflowQueue = scope.ServiceProvider.GetRequiredService<IWorkflowQueue>();
await workflowQueue.EnqueueWorkflowsAsync<MessageReceivedTrigger>(
x => x.QueueName == _messageReceiver.Path && (string.IsNullOrWhiteSpace(x.CorrelationId) || x.CorrelationId == message.CorrelationId),
x => x.QueueName == _messageReceiver.Path && (string.Equals(x.CorrelationId, message.CorrelationId)),
message, message.CorrelationId,
cancellationToken: cancellationToken);
}