mmucklo / DtcQueueBundle

ODM/JobManager.php

Doc Comments +3 added lines, -2 removed lines

@@ -208,6 +208,7 @@ 
      * @param string $workerName
      * @param string $methodName
      * @param bool   $prioritize
+     * @param integer $runId
      *
      * @return \Dtc\QueueBundle\Model\Job
      */
@@ -233,8 +234,8 @@ 
     }
 
     /**
-     * @param null $workerName
-     * @param null $methodName
+     * @param string|null $workerName
+     * @param string|null $methodName
      * @param bool $prioritize
      *
      * @return Builder

ORM/JobManager.php

Doc Comments +8 added lines, -3 removed lines

@@ -239,6 +239,7 @@ 
      * @param string $workerName
      * @param string $methodName
      * @param bool   $prioritize
+     * @param integer $runId
      *
      * @return Job|null
      */
@@ -255,8 +256,8 @@ 
     }
 
     /**
-     * @param null $workerName
-     * @param null $methodName
+     * @param string|null $workerName
+     * @param string|null $methodName
      * @param bool $prioritize
      *
      * @return QueryBuilder
@@ -332,7 +333,7 @@ 
      *
      * @param \Dtc\QueueBundle\Model\Job $job
      *
-     * @return mixed|null
+     * @return null|Job
      */
     public function updateNearestBatch(\Dtc\QueueBundle\Model\Job $job)
     {
@@ -361,6 +362,10 @@ 
         return $existingJob;
     }
 
+    /**
+     * @param integer $newPriority
+     * @param null|\DateTime $newWhenAt
+     */
     protected function updateBatchJob(Job $existingJob, $newPriority, $newWhenAt)
     {
         $existingPriority = $existingJob->getPriority();