mmucklo / DtcQueueBundle

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);

Redis/StatusTrait.php

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);

DependencyInjection/RedisConfiguration.php

Spacing +5 added lines, -5 removed lines

@@ -15,7 +15,7 @@ 
             ->scalarNode('dsn')->defaultNull()->end()
             ->append($this->addPredisArgs())
             ->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if (isset($node['dsn']) && (isset($node['connection_parameters']['host']) || isset($node['connection_parameters']['port']))) {
                     return true;
                 }
@@ -58,7 +58,7 @@ 
             ->append($this->addPredis())
             ->append($this->addPhpRedisArgs())
             ->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if ($this->checkPredis($node)) {
                     return true;
                 }
@@ -86,7 +86,7 @@ 
             ->floatNode('read_timeout')->defaultValue(0)->end()
             ->scalarNode('auth')->end()
             ->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if (!empty($node) && !isset($node['host'])) {
                     return true;
                 }
@@ -119,7 +119,7 @@ 
             ->booleanNode('iterable_multibulk')->defaultFalse()->end()
             ->booleanNode('throw_errors')->defaultTrue()->end()
             ->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if (isset($node['host']) && !isset($node['port'])) {
                     return true;
                 }
@@ -145,7 +145,7 @@ 
             ->scalarNode('alias')
             ->defaultNull()->end()
             ->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if (isset($node['type']) && !isset($node['alias'])) {
                     return true;
                 }

DependencyInjection/RabbitMQConfiguration.php

Spacing +3 added lines, -3 removed lines

@@ -32,7 +32,7 @@ 
         $rootNode
             ->prototype('variable')->end()
             ->validate()
-            ->ifTrue(function ($node) {
+            ->ifTrue(function($node) {
                 if (!is_array($node)) {
                     return true;
                 }
@@ -109,7 +109,7 @@ 
             ->append($this->addRabbitMqArgs())
             ->append($this->addRabbitMqExchange())
             ->end()
-            ->validate()->always(function ($node) {
+            ->validate()->always(function($node) {
                 if (empty($node['ssl_options'])) {
                     unset($node['ssl_options']);
                 }
@@ -119,7 +119,7 @@ 
 
                 return $node;
             })->end()
-            ->validate()->ifTrue(function ($node) {
+            ->validate()->ifTrue(function($node) {
                 if (isset($node['ssl_options']) && !$node['ssl']) {
                     return true;
                 }

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 = $this->determineFormatLength($maxLength);

Command/CreateJobCommand.php

Spacing +2 added lines, -2 removed lines

@@ -63,11 +63,11 @@
             $this->getName(), // command
             'my-worker-name', // worker_name
             'myMethod', // method
-            json_encode([ // args
+            json_encode([// args
                 'first parameter', // argv[0] (string)
                 null, // argv[1] (null)
                 3, // argv[2] (int)
-                [ // argv[3] (array)
+                [// argv[3] (array)
                     'fourth',
                     'param',
                     'is',

Redis/Predis.php

Spacing +2 added lines, -2 removed lines

@@ -159,7 +159,7 @@ 
         ];
 
         try {
-            $this->predis->transaction($options, function (MultiExec $tx) use ($key, &$element) {
+            $this->predis->transaction($options, function(MultiExec $tx) use ($key, &$element) {
                 $zRange = $tx->zrange($key, 0, 0);
                 $element = isset($zRange[0]) ? $zRange[0] : null;
 
@@ -185,7 +185,7 @@ 
         ];
 
         try {
-            $this->predis->transaction($options, function (MultiExec $tx) use ($key, $max, &$element) {
+            $this->predis->transaction($options, function(MultiExec $tx) use ($key, $max, &$element) {
                 $zRangeByScore = $tx->zrangebyscore($key, 0, $max, ['LIMIT' => [0, 1]]);
                 $element = isset($zRangeByScore[0]) ? $zRangeByScore[0] : null;
 

Model/Worker.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
             $hasEnDecimalPoint = $decimalPoint === '.' ? $hasDecimalPoint : strpos(strval($time), '.');
             if (!$hasEnDecimalPoint) {
                 if ($hasDecimalPoint) {
-                    $dateTime = \DateTime::createFromFormat('U' . $decimalPoint . 'u', strval($timeU),
+                    $dateTime = \DateTime::createFromFormat('U'.$decimalPoint.'u', strval($timeU),
                         new \DateTimeZone(date_default_timezone_get()));
                 } else {
                     $dateTime = \DateTime::createFromFormat('U', strval($timeU),

DependencyInjection/Compiler/GridCompilerPass.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
         $defaultManagerType = $container->getParameter('dtc_queue.manager.job');
         $runManagerType = $container->getParameter($this->getRunManagerType($container));
         if ($defaultManagerType === 'orm' || $runManagerType === 'orm' || $defaultManagerType === 'odm' || $runManagerType === 'odm') {
-            $filename =__DIR__ . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'Resources' . DIRECTORY_SEPARATOR . 'dtc_grid.yaml';
+            $filename = __DIR__.DIRECTORY_SEPARATOR.'..'.DIRECTORY_SEPARATOR.'..'.DIRECTORY_SEPARATOR.'Resources'.DIRECTORY_SEPARATOR.'dtc_grid.yaml';
             $cacheDir = $container->getParameter('kernel.cache_dir');
             if (class_exists('Dtc\GridBundle\Grid\Source\ColumnSource')) {
                 \Dtc\GridBundle\Grid\Source\ColumnSource::cacheClassesFromFile($cacheDir, $filename);