mmucklo / DtcQueueBundle

Tests/Manager/BaseJobManagerTest.php

Doc Comments +3 added lines

@@ -207,6 +207,9 @@
         return $count;
     }
 
+    /**
+     * @param integer $expected
+     */
     protected static function getWaitingJobCount($expected)
     {
         $count = self::$jobManager->getWaitingJobCount();

Tests/RabbitMQ/JobManagerTest.php

Doc Comments +3 added lines

@@ -252,6 +252,9 @@
         self::$jobManager->saveHistory($jobInQueue);
     }
 
+    /**
+     * @param \PhpAmqpLib\Channel\AMQPChannel $channel
+     */
     protected static function drainQueue($channel)
     {
         $drained = 0;

Redis/JobManager.php

Doc Comments +5 added lines

@@ -153,6 +153,7 @@ 
     /**
      * @param string   $crcCacheKey
      * @param int|null $newFoundPriority
+     * @param string $foundJobCacheKey
      */
     protected function finishBatchFoundJob(Job $foundJob, $foundJobCacheKey, $crcCacheKey, $newFoundWhen, $newFoundPriority)
     {
@@ -175,6 +176,7 @@ 
 
     /**
      * @param bool $adjust
+     * @param string $crcCacheKey
      */
     protected function addFoundJob($adjust, Job $foundJob, $foundJobCacheKey, $crcCacheKey)
     {
@@ -427,6 +429,9 @@ 
         return true;
     }
 
+    /**
+     * @param string $cacheKey
+     */
     private function collateStatusResults(array &$results, $cacheKey)
     {
         $cursor = null;

Doctrine/DoctrineJobManager.php

Doc Comments +10 added lines

@@ -63,6 +63,10 @@ 
         }
     }
 
+    /**
+     * @param string $workerName
+     * @param string $method
+     */
     public function pruneExpiredJobs($workerName = null, $method = null)
     {
         $count = $this->updateExpired($workerName, $method);
@@ -305,6 +309,9 @@ 
      */
     abstract protected function stopIdGenerator($objectName);
 
+    /**
+     * @param string $objectName
+     */
     abstract protected function restoreIdGenerator($objectName);
 
     /**
@@ -341,6 +348,9 @@ 
         return $countProcessed;
     }
 
+    /**
+     * @param string $function
+     */
     protected function resetSaveOk($function)
     {
     }