From 85c77f0e24820b1737617777f87790179dd5e4e2 Mon Sep 17 00:00:00 2001 From: Sebastian Stehle Date: Mon, 2 Oct 2017 20:49:21 +0200 Subject: [PATCH] Deadlock fixed --- .../CQRS/Events/Actors/EventConsumerActor.cs | 3 ++- src/Squidex.Infrastructure/ExceptionHelper.cs | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs index 63f5f4e7f..67abb9778 100644 --- a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs +++ b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs @@ -195,7 +195,8 @@ namespace Squidex.Infrastructure.CQRS.Events.Actors private async Task StopAsync(Exception exception = null) { - await eventSubscription.StopAsync(); + eventSubscription.StopAsync().Forget(); + await eventConsumerInfoRepository.StopAsync(eventConsumer.Name, exception?.ToString()); } diff --git a/src/Squidex.Infrastructure/ExceptionHelper.cs b/src/Squidex.Infrastructure/ExceptionHelper.cs index 02b50998d..e40ddc5cd 100644 --- a/src/Squidex.Infrastructure/ExceptionHelper.cs +++ b/src/Squidex.Infrastructure/ExceptionHelper.cs @@ -21,7 +21,7 @@ namespace Squidex.Infrastructure return aggregateException.InnerExceptions.Count == 1 && Is(aggregateException.InnerExceptions[0]); } - return ex is OperationCanceledException; + return ex is T; } } }