always add version to query to use indexes

prooph · Mar 12, 2017 · 7f7996d · 7f7996d
1 parent a70c6e9
commit 7f7996d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/Aggregate/AggregateRepository.php b/src/Aggregate/AggregateRepository.php
@@ -161,6 +161,11 @@ public function getAggregateRoot(string $aggregateId)
                 Operator::EQUALS(),
                 $aggregateId
             );
+            $metadataMatcher = $metadataMatcher->withMetadataMatch(
+                '_aggregate_version',
+                Operator::GREATER_THAN_EQUALS(),
+                1
+            );
 
             try {
                 $streamEvents = $this->eventStore->load($streamName, 1, null, $metadataMatcher);