diff --git a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs index 67abb9778..2536f57d4 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) { - eventSubscription.StopAsync().Forget(); + eventSubscription?.StopAsync().Forget(); + eventSubscription = null; await eventConsumerInfoRepository.StopAsync(eventConsumer.Name, exception?.ToString()); }