From 53d06ee5ca6fe15e8bef571cca58cc78df1f52fa Mon Sep 17 00:00:00 2001
From: Hugues Maignol <hugues.maignol@kitpages.fr>
Date: Tue, 26 Jan 2016 10:41:07 +0100
Subject: [PATCH] Repository::add() void

---
 src/Doctrine/ODM/MongoDB/AbstractMongoRepository.php | 4 +---
 src/Doctrine/ORM/AbstractORMRepository.php           | 6 ++----
 src/MessageBus/Middleware/PersistsMessages.php       | 2 ++
 3 files changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/Doctrine/ODM/MongoDB/AbstractMongoRepository.php b/src/Doctrine/ODM/MongoDB/AbstractMongoRepository.php
index 693b61f..81d2d5f 100644
--- 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
index caf6436..dfc598f 100644
--- 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
index 661416f..22b4f6f 100644
--- 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) {