Repository::add() void

hugues-m · Jan 26, 2016 · 53d06ee · 53d06ee
1 parent 8e0f6a1
commit 53d06ee
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git a/src/Doctrine/ODM/MongoDB/AbstractMongoRepository.php b/src/Doctrine/ODM/MongoDB/AbstractMongoRepository.php
@@ -52,13 +52,11 @@ public function get(Identity $identity)
     /**
      * @param AggregateRoot $document
      *
-     * @return self
+     * @return void
      */
     public function add(AggregateRoot $document)
     {
         $this->dm->persist($document);
-
-        return $this;
     }
 
     /**

diff --git a/src/Doctrine/ORM/AbstractORMRepository.php b/src/Doctrine/ORM/AbstractORMRepository.php
@@ -52,13 +52,11 @@ public function get(Identity $identity): AggregateRoot
     /**
      * @param AggregateRoot $document
      *
-     * @return self
+     * @return void
      */
-    public function add(AggregateRoot $document): self
+    public function add(AggregateRoot $document)
     {
         $this->em->persist($document);
-
-        return $this;
     }
 
     /**

diff --git a/src/MessageBus/Middleware/PersistsMessages.php b/src/MessageBus/Middleware/PersistsMessages.php
@@ -1,4 +1,5 @@
 <?php
+declare (strict_types = 1);
 
 namespace HMLB\DDDBundle\MessageBus\Middleware;
 
@@ -61,6 +62,7 @@ public function __construct(LoggerInterface $logger, ObjectManager $om, bool $pe
     public function handle($message, callable $next)
     {
         if ($message instanceof PersistentMessage && $this->shouldPersistMessage($message)) {
+            $this->logger->debug('PersistsMessage persisting '.get_class($message));
             try {
                 $message->getId();
             } catch (PersistentMessageWithoutIdentityException $e) {