mmucklo / DtcQueueBundle

ORM/JobManager.php

Doc Comments +1 added lines, -1 removed lines

@@ -212,7 +212,7 @@
      * @param bool   $prioritize
      * @param int    $runId
      *
-     * @return Job|null
+     * @return boolean|null
      */
     public function getJob($workerName = null, $methodName = null, $prioritize = true, $runId = null)
     {

Redis/StatusTrait.php

Doc Comments +3 added lines

@@ -6,6 +6,9 @@
 
 trait StatusTrait
 {
+    /**
+     * @param string $cacheKey
+     */
     protected 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/RabbitMQ/JobManagerTest.php

Doc Comments +3 added lines

@@ -180,6 +180,9 @@
         );
     }
 
+    /**
+     * @param \PhpAmqpLib\Channel\AMQPChannel $channel
+     */
     protected static function drainQueue($channel)
     {
         $drained = 0;