heristop / HeriJobQueueBundle

Adapter/AmqpAdapter.php

Doc Comments +1 added lines, -1 removed lines

@@ -187,7 +187,7 @@
      *
      * @param int|null             $maxMessages Maximum number of messages to return
      * @param int|null             $timeout     Visibility timeout for these messages
-     * @param null|ZendQueue\Queue $queue
+     * @param null|Queue $queue
      *
      * @return ZendQueue\MessageIterator
      */

Adapter/DoctrineAdapter.php

Doc Comments +6 added lines, -6 removed lines

@@ -148,7 +148,7 @@ 
     /**
      * Return the approximate number of messages in the queue.
      *
-     * @param ZendQueue\Queue $queue
+     * @param Queue $queue
      *
      * @return int
      *
@@ -179,7 +179,7 @@ 
      * Send a message to the queue.
      *
      * @param string          $message Message to send to the active queue
-     * @param ZendQueue\Queue $queue
+     * @param Queue $queue
      *
      * @return ZendQueue\Message
      *
@@ -222,7 +222,7 @@ 
      *
      * @param int             $maxMessages Maximum number of messages to return
      * @param int             $timeout     Visibility timeout for these messages
-     * @param ZendQueue\Queue $queue
+     * @param Queue $queue
      *
      * @return ZendQueue\MessageIterator
      *
@@ -275,7 +275,7 @@ 
      * Returns true if the message is deleted, false if the deletion is
      * unsuccessful.
      *
-     * @param ZendQueue\Message $message
+     * @param Message $message
      *
      * @return bool
      *
@@ -301,7 +301,6 @@ 
      * $array['function name'] = true or false
      * true is supported, false is not supported.
      *
-     * @param string $name
      *
      * @return array
      */
@@ -321,6 +320,7 @@ 
 
     /**
      * {@inheritdoc}
+     * @param integer $priority
      */
     public function setPriority($priority)
     {
@@ -396,7 +396,7 @@ 
     /**
      * Create a new message.
      *
-     * @param ZendQueue\Queue $queue
+     * @param Queue $queue
      * @param string          $body
      */
     protected function createMessage(Queue $queue, $body)

Service/QueueService.php

Doc Comments +8 added lines, -4 removed lines

@@ -125,7 +125,6 @@ 
 
     /**
      * @param array $args
-     * @param int   $priority
      */
     public function push(array $args)
     {
@@ -142,7 +141,6 @@ 
     }
 
     /**
-     * @param string $name
      *
      * @return $this
      */
@@ -243,6 +241,9 @@ 
         $this->processTimeout = $processTimeout;
     }
 
+    /**
+     * @param string $name
+     */
     public function listen($name = null, $sleep = 0, $work = true)
     {
         if ($work) {
@@ -304,7 +305,7 @@ 
     }
 
     /**
-     * @param MessageIterator $messages
+     * @param \ZendQueue\Message\MessageIterator $messages
      */
     protected function handle(\ZendQueue\Message\MessageIterator $messages)
     {
@@ -317,6 +318,9 @@ 
         }
     }
 
+    /**
+     * @param \ZendQueue\Message $message
+     */
     protected function run($message)
     {
         if (property_exists($this->adapter, 'logger')) {
@@ -359,7 +363,7 @@ 
     }
 
     /**
-     * @param ZendQueue\Message $message
+     * @param \ZendQueue\Message $message
      */
     protected function getUnseralizedBody(\ZendQueue\Message $message)
     {