mmucklo / DtcQueueBundle

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;

Spacing +1 added lines, -1 removed lines

@@ -431,7 +431,7 @@
     {
         $cursor = null;
         while ($jobs = $this->redis->zScan($cacheKey, $cursor, '', 100)) {
-            $jobs = $this->redis->mget(array_map(function ($item) {
+            $jobs = $this->redis->mget(array_map(function($item) {
                 return $this->getJobCacheKey($item);
             }, array_keys($jobs)));
             $this->extractStatusResults($jobs, $results);

Tests/Redis/PredisPhpRedisTest.php

Doc Comments +6 added lines

@@ -106,6 +106,9 @@ 
         self::assertEquals(3, $result[$hashKey2]);
     }
 
+    /**
+     * @param string $haskKeyStart
+     */
     private function prePopulateScan($type, $haskKeyStart, array &$hashKeys)
     {
         for ($i = 0; $i < 100; ++$i) {
@@ -121,6 +124,9 @@ 
         }
     }
 
+    /**
+     * @param string $type
+     */
     public function scan(RedisInterface $redis, $type)
     {
         $key = 'testHash';