sonata-project / SonataNotificationBundle

src/Iterator/MessageManagerMessageIterator.php

Doc Comments +1 added lines, -1 removed lines

@@ -147,7 +147,7 @@
      *
      * @param array $types
      *
-     * @return mixed
+     * @return MessageInterface[]
      */
     protected function findNextMessages($types)
     {

tests/Entity/Message.php

Doc Comments +3 added lines

@@ -16,6 +16,9 @@
 
 class Message extends BaseMessage
 {
+    /**
+     * @param integer $id
+     */
     public function setId($id)
     {
         $this->id = $id;

tests/Backend/AMQPBackendTest.php

Doc Comments +4 added lines

@@ -298,6 +298,10 @@
     }
 
     /**
+     * @param string $deadLetterExchange
+     * @param string $deadLetterRoutingKey
+     * @param integer $ttl
+     * @param integer $prefetchCount
      * @return AMQPBackend
      */
     protected function buildBackend($recover = false, $deadLetterExchange = null, $deadLetterRoutingKey = null, $ttl = null, $prefetchCount = null)

tests/Entity/MessageManagerTest.php

Doc Comments +1 added lines

@@ -162,6 +162,7 @@
     }
 
     /**
+     * @param \Closure $qbCallback
      * @return MessageManager
      */
     protected function getMessageManager($qbCallback)

tests/Iterator/AMQPMessageIteratorTest.php

Doc Comments +3 added lines, -3 removed lines

@@ -66,9 +66,9 @@ 
     }
 
     /**
-     * @param mixed $queueName
+     * @param string $queueName
      *
-     * @return AmqpConsumer|\PHPUnit_Framework_MockObject_MockObject
+     * @return AmqpConsumer
      */
     private function createConsumerStub($queueName = null)
     {
@@ -90,7 +90,7 @@ 
     }
 
     /**
-     * @return AMQPChannel|\PHPUnit_Framework_MockObject_MockObject|AMQPChannel
+     * @return AMQPChannel
      */
     private function createChannelMock()
     {

src/Model/MessageManagerInterface.php

Doc Comments +5 added lines, -3 removed lines

@@ -24,12 +24,14 @@ 
     public function countStates();
 
     /**
-     * @param $maxAge
+     * @param integer $maxAge
+     * @return void
      */
     public function cleanup($maxAge);
 
     /**
      * Cancels a given Message.
+     * @return void
      */
     public function cancel(MessageInterface $message);
 
@@ -51,8 +53,8 @@ 
 
     /**
      * @param      $state
-     * @param      $batchSize
-     * @param null $maxAttempts
+     * @param      integer $batchSize
+     * @param integer $maxAttempts
      * @param int  $attemptDelay
      *
      * @return mixed

src/Command/ConsumerHandlerCommand.php

Doc Comments +1 added lines, -1 removed lines

@@ -156,7 +156,7 @@
     }
 
     /**
-     * @param $memory
+     * @param integer $memory
      *
      * @return string
      */