From 77a10ebc7ef953992225538bdb82bf7478219457 Mon Sep 17 00:00:00 2001 From: Sebastian Stehle Date: Wed, 4 Oct 2017 01:12:02 +0200 Subject: [PATCH] Position fixed --- .../CQRS/Events/PollingSubscription.cs | 1 + .../CQRS/Events/Actors/EventConsumerActor.cs | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs b/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs index ca95e20de..196809500 100644 --- a/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs +++ b/src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs @@ -42,6 +42,7 @@ namespace Squidex.Infrastructure.CQRS.Events public PollingSubscription(MongoEventStore store, IEventNotifier notifier, IEventSubscriber subscriber, string streamFilter, string position) { this.notifier = notifier; + this.position = position; this.store = store; this.streamFilter = streamFilter; this.subscriber = subscriber; diff --git a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs index 2536f57d4..12656e586 100644 --- a/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs +++ b/src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs @@ -188,7 +188,7 @@ namespace Squidex.Infrastructure.CQRS.Events.Actors { var status = await eventConsumerInfoRepository.FindAsync(eventConsumer.Name); - eventSubscription = eventStore.CreateSubscription(this, streamFilter: eventConsumer.EventsFilter, position: status.Position); + eventSubscription = eventStore.CreateSubscription(this, eventConsumer.EventsFilter, status.Position); await eventConsumerInfoRepository.StartAsync(eventConsumer.Name); }