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 @@ shouldPersistMessage($message)) { + $this->logger->debug('PersistsMessage persisting '.get_class($message)); try { $message->getId(); } catch (PersistentMessageWithoutIdentityException $e) {