Browse Source

Deadlock fixed

pull/131/head
Sebastian Stehle 9 years ago
parent
commit
85c77f0e24
  1. 3
      src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs
  2. 2
      src/Squidex.Infrastructure/ExceptionHelper.cs

3
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) private async Task StopAsync(Exception exception = null)
{ {
await eventSubscription.StopAsync(); eventSubscription.StopAsync().Forget();
await eventConsumerInfoRepository.StopAsync(eventConsumer.Name, exception?.ToString()); await eventConsumerInfoRepository.StopAsync(eventConsumer.Name, exception?.ToString());
} }

2
src/Squidex.Infrastructure/ExceptionHelper.cs

@ -21,7 +21,7 @@ namespace Squidex.Infrastructure
return aggregateException.InnerExceptions.Count == 1 && Is<T>(aggregateException.InnerExceptions[0]); return aggregateException.InnerExceptions.Count == 1 && Is<T>(aggregateException.InnerExceptions[0]);
} }
return ex is OperationCanceledException; return ex is T;
} }
} }
} }

Loading…
Cancel
Save