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 +5 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
      */
@@ -396,7 +395,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 +5 added lines, -4 removed lines

@@ -124,7 +124,6 @@ 
 
     /**
      * @param array $args
-     * @param int   $priority
      */
     public function push(array $args)
     {
@@ -141,7 +140,6 @@ 
     }
 
     /**
-     * @param string $name
      *
      * @return $this
      */
@@ -303,7 +301,7 @@ 
     }
 
     /**
-     * @param MessageIterator $messages
+     * @param \ZendQueue\Message\MessageIterator $messages
      */
     protected function handle(\ZendQueue\Message\MessageIterator $messages)
     {
@@ -316,6 +314,9 @@ 
         }
     }
 
+    /**
+     * @param \ZendQueue\Message $message
+     */
     protected function run($message)
     {
         if (property_exists($this->adapter, 'logger')) {
@@ -358,7 +359,7 @@ 
     }
 
     /**
-     * @param ZendQueue\Message $message
+     * @param \ZendQueue\Message $message
      */
     protected function getUnseralizedBody(\ZendQueue\Message $message)
     {

Unused Use Statements -1 removed lines

@@ -18,7 +18,6 @@
 use Symfony\Component\Console\Output\ConsoleOutput;
 use Symfony\Component\Console\Output\StreamOutput;
 use Symfony\Component\Process\Process;
-use Heri\Bundle\JobQueueBundle\Exception\CommandFindException;
 use Heri\Bundle\JobQueueBundle\Exception\InvalidUnserializedMessageException;
 
 class QueueService