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;

Command/CountCommand.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
         $firstJob = key($status);
         if ($firstJob) {
             $jobKeys = array_keys($status);
-            $maxLength = max(array_map(function ($item) {
+            $maxLength = max(array_map(function($item) {
                 return strlen($item ?: '');
             }, $jobKeys));
             $formatLen = $maxLength > 50 ? 50 : $maxLength;

Controller/QueueController.php

Spacing +2 added lines, -2 removed lines

@@ -128,7 +128,7 @@ 
         $workerName = $request->get('workerName');
         $methodName = $request->get('method');
         $total = null;
-        $callback = function ($count, $totalCount) use (&$total) {
+        $callback = function($count, $totalCount) use (&$total) {
             if (null !== $totalCount && null === $total) {
                 $total = $totalCount;
                 echo json_encode(['total' => $total]);
@@ -142,7 +142,7 @@ 
             flush();
         };
 
-        return function () use ($jobManager, $callback, $workerName, $methodName, $functionName, &$total) {
+        return function() use ($jobManager, $callback, $workerName, $methodName, $functionName, &$total) {
             switch ($functionName) {
                 case 'archiveAllJobs':
                     $total = $jobManager->countLiveJobs($workerName, $methodName);