From 510109fd0567ad9e7c75b2c80b2943c09a8ce426 Mon Sep 17 00:00:00 2001 From: Sebastian Stehle Date: Sun, 22 Oct 2017 18:40:21 +0200 Subject: [PATCH] Bugfixes --- .../Apps/MongoAppEntity.cs | 1 - .../CQRS/Events/GetEventStoreSubscription.cs | 11 +++++------ 2 files changed, 5 insertions(+), 7 deletions(-) diff --git a/src/Squidex.Domain.Apps.Read.MongoDb/Apps/MongoAppEntity.cs b/src/Squidex.Domain.Apps.Read.MongoDb/Apps/MongoAppEntity.cs index b86fd0f75..46e1f5e9e 100644 --- a/src/Squidex.Domain.Apps.Read.MongoDb/Apps/MongoAppEntity.cs +++ b/src/Squidex.Domain.Apps.Read.MongoDb/Apps/MongoAppEntity.cs @@ -10,7 +10,6 @@ using MongoDB.Bson.Serialization.Attributes; using Squidex.Domain.Apps.Core; using Squidex.Domain.Apps.Core.Apps; using Squidex.Domain.Apps.Read.Apps; -using Squidex.Infrastructure; using Squidex.Infrastructure.MongoDb; namespace Squidex.Domain.Apps.Read.MongoDb.Apps diff --git a/src/Squidex.Infrastructure.GetEventStore/CQRS/Events/GetEventStoreSubscription.cs b/src/Squidex.Infrastructure.GetEventStore/CQRS/Events/GetEventStoreSubscription.cs index 8f6ae46d3..53799cf95 100644 --- a/src/Squidex.Infrastructure.GetEventStore/CQRS/Events/GetEventStoreSubscription.cs +++ b/src/Squidex.Infrastructure.GetEventStore/CQRS/Events/GetEventStoreSubscription.cs @@ -20,7 +20,7 @@ using Squidex.Infrastructure.Tasks; namespace Squidex.Infrastructure.CQRS.Events { - internal sealed class GetEventStoreSubscription : DisposableObjectBase, IEventSubscription + internal sealed class GetEventStoreSubscription : IEventSubscription { private const string ProjectionName = "by-{0}-{1}"; private static readonly ConcurrentDictionary SubscriptionsCreated = new ConcurrentDictionary(); @@ -57,12 +57,11 @@ namespace Squidex.Infrastructure.CQRS.Events subscription = SubscribeToStream(streamName); } - protected override void DisposeObject(bool disposing) + public Task StopAsync() { - if (disposing) - { - subscription.Stop(); - } + subscription.Stop(); + + return TaskHelper.Done; } private EventStoreCatchUpSubscription SubscribeToStream(string streamName)