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

Cleanup

Browse source
This commit is contained in:
Sipke Schoorstra 2021-01-16 12:52:08 +01:00
parent 4ebd41cc21
commit d3196eea22
1 changed files with 14 additions and 25 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -40,41 +40,30 @@ namespace Elsa.Activities.AzureServiceBus.Services
{
using var scope = _serviceProvider.CreateScope();
var workflowRunner = scope.ServiceProvider.GetRequiredService<IWorkflowRunner>();
if (string.IsNullOrWhiteSpace(message.CorrelationId))
{
await workflowRunner.TriggerWorkflowsAsync<MessageReceivedTrigger>(
x => x.QueueName == _messageReceiver.Path && (x.CorrelationId == null),
message,
message.CorrelationId,
cancellationToken: cancellationToken);
}
else
{
await workflowRunner.TriggerWorkflowsAsync<MessageReceivedTrigger>(
x => x.QueueName == _messageReceiver.Path && x.CorrelationId == message.CorrelationId,
message,
message.CorrelationId,
cancellationToken: cancellationToken);
}
Func<MessageReceivedTrigger, bool> predicate = string.IsNullOrWhiteSpace(message.CorrelationId)
? x => x.QueueName == _messageReceiver.Path && x.CorrelationId == null
: x => x.QueueName == _messageReceiver.Path && x.CorrelationId == message.CorrelationId;
await workflowRunner.TriggerWorkflowsAsync(
predicate,
message,
message.CorrelationId,
cancellationToken: cancellationToken);
}
private Task ExceptionReceivedHandler(ExceptionReceivedEventArgs e)
{
var context = e.ExceptionReceivedContext;
switch (e.Exception)
{
case MessageLockLostException:
_logger.LogDebug( e.Exception,"Message lock lost");
break;
case ServiceBusCommunicationException:
_logger.LogDebug(e.Exception.Message);
_logger.LogDebug(e.Exception, "Lost service bus communication");
break;
default:
_logger.LogError("Message handler encountered an exception {Exception}.", e.Exception);
_logger.LogError("Exception context for troubleshooting:");
_logger.LogError("- Endpoint: {Endpoint}", context.Endpoint);
_logger.LogError("- Entity Path: {EntityPath}", context.EntityPath);
_logger.LogError("- Executing Action: {Action}", context.Action);
_logger.LogError(e.Exception, "Unhandled exception");
break;
}