Added calling of EntityManager::flush() in method `DoctrineAggregat…

…eRootRepository::saveAggregateRoot()`
68publishers · Feb 23, 2024 · 9e4b902 · 9e4b902
1 parent 9d6157e
commit 9e4b902
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...ArchitectureBundle/Infrastructure/Doctrine/Repository/DoctrineAggregateRootRepository.php b/...ArchitectureBundle/Infrastructure/Doctrine/Repository/DoctrineAggregateRootRepository.php
@@ -36,6 +36,9 @@ public function saveAggregateRoot(AggregateRootInterface $aggregateRoot): void
         $this->em->persist($aggregateRoot);
 
         $this->eventStore->store($aggregateRootClassname, $events);
+
+        $this->em->flush();
+
         $this->eventPublisher->publish($aggregateRootClassname, $aggregateRoot->getAggregateId(), $events);
     }
 }