change to greater than equals for version matching

prooph · Jan 22, 2017 · f5ef825 · f5ef825
1 parent d6b333b
commit f5ef825
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/AbstractAggregateDefiniton.php b/src/AbstractAggregateDefiniton.php
@@ -73,7 +73,7 @@ public function metadataMatcher(string $aggregateId, int $aggregateVersion): ?Me
             ->withMetadataMatch('_aggregate_type', Operator::EQUALS(), $this->aggregateType())
 
             // this is only required when using one stream per aggregate type
-            ->withMetadataMatch('_aggregate_version', Operator::EQUALS(), $aggregateVersion);
+            ->withMetadataMatch('_aggregate_version', Operator::GREATER_THAN_EQUALS(), $aggregateVersion);
     }
 
     public function metadataEnricher(string $aggregateId, int $aggregateVersion): ?MetadataEnricher