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

Handle ServiceBusCommunicationException

Browse source
This commit is contained in:
Sipke Schoorstra 2020-12-21 14:21:19 +01:00
parent cc91da842c
commit ee89331b91
1 changed files with 12 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -46,17 +46,19 @@ namespace Elsa.Activities.AzureServiceBus.Services
{
var context = e.ExceptionReceivedContext;
if (e.Exception is MessageLockLostException)
switch (e.Exception)
{
_logger.LogDebug("Message lock lost.");
}
else
{
_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);
case MessageLockLostException:
case ServiceBusCommunicationException:
_logger.LogDebug(e.Exception.Message);
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);
break;
}
return Task.CompletedTask;