sfcod / jobqueue

Base/JobInterface.php

Doc Comments +1 added lines

@@ -16,6 +16,7 @@
      *
      * @param Job $job
      * @param array $data
+     * @return void
      */
     public function fire(Job $job, array $data);
 }

Queue/MongoQueue.php

Doc Comments +4 added lines, -4 removed lines

@@ -96,7 +96,7 @@ 
      *
      * @param string $queue
      *
-     * @return null|Job
+     * @return MongoJob|null
      */
     public function pop($queue = null)
     {
@@ -116,7 +116,7 @@ 
      * @param mixed $data
      * @param string $queue
      *
-     * @return mixed
+     * @return boolean
      */
     public function exists($job, $data = '', $queue = null)
     {
@@ -196,7 +196,7 @@ 
      *
      * @param $id
      *
-     * @return null|Job
+     * @return null|MongoJob
      */
     public function getJobById($id)
     {
@@ -344,7 +344,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return null|Job
+     * @return MongoJob|null
      */
     protected function getNextAvailableJob($queue)
     {

Service/JobQueue.php

Doc Comments +2 added lines, -3 removed lines

@@ -125,7 +125,7 @@ 
     /**
      * Push a new job onto the queue after a delay.
      *
-     * @param \DateTime|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue
@@ -141,7 +141,7 @@ 
     /**
      * Push a new job into the queue after a delay if job does not exist.
      *
-     * @param \DateTime|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue
@@ -162,7 +162,6 @@ 
      * Add connector
      *
      * @param string $name
-     * @param Closure $resolver
      */
     public function addConnector(string $name, ConnectorInterface $connector)
     {

Command/RetryCommand.php

Doc Comments -1 removed lines

@@ -35,7 +35,6 @@
      * RetryCommand constructor.
      *
      * @param JobQueue $queue
-     * @param MongoDriverInterface $mongoDriver
      */
     public function __construct(JobQueue $queue, MongoFailedJobProvider $failer)
     {

Command/RunJobCommand.php

Doc Comments -1 removed lines

@@ -25,7 +25,6 @@
     /**
      * RunJobCommand constructor.
      *
-     * @param LoggerInterface $logger
      * @param Worker $worker
      */
     public function __construct(Worker $worker)

Worker.php

Doc Comments +1 added lines, -2 removed lines

@@ -70,9 +70,8 @@
     /**
      * Create a new queue worker.
      *
-     * @param QueueManager $manager
      * @param MongoFailedJobProvider $failer
-     * @param ExceptionHandler $exceptions
+     * @param ExceptionHandlerInterface $exceptions
      */
     public function __construct(JobQueue $queue,
                                 JobProcess $process,