diff --git a/Neos.ContentRepository.Core/Classes/ContentRepository.php b/Neos.ContentRepository.Core/Classes/ContentRepository.php index 311be1255a4..91e63ac6970 100644 --- a/Neos.ContentRepository.Core/Classes/ContentRepository.php +++ b/Neos.ContentRepository.Core/Classes/ContentRepository.php @@ -166,6 +166,9 @@ public function catchUpProjection(string $projectionClassName, CatchUpOptions $o // TODO allow custom stream name per projection $streamName = VirtualStreamName::all(); $eventStream = $this->eventStore->load($streamName); + if ($options->maximumSequenceNumber !== null) { + $eventStream = $eventStream->withMaximumSequenceNumber($options->maximumSequenceNumber); + } $eventApplier = function (EventEnvelope $eventEnvelope) use ($projection, $catchUpHook) { $event = $this->eventNormalizer->denormalize($eventEnvelope->event);