Browse Source

Position fixed

pull/131/head
Sebastian Stehle 9 years ago
parent
commit
77a10ebc7e
  1. 1
      src/Squidex.Infrastructure.MongoDb/CQRS/Events/PollingSubscription.cs
  2. 2
      src/Squidex.Infrastructure/CQRS/Events/Actors/EventConsumerActor.cs

1
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) public PollingSubscription(MongoEventStore store, IEventNotifier notifier, IEventSubscriber subscriber, string streamFilter, string position)
{ {
this.notifier = notifier; this.notifier = notifier;
this.position = position;
this.store = store; this.store = store;
this.streamFilter = streamFilter; this.streamFilter = streamFilter;
this.subscriber = subscriber; this.subscriber = subscriber;

2
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); 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); await eventConsumerInfoRepository.StartAsync(eventConsumer.Name);
} }

Loading…
Cancel
Save