resquebundle / resque

Command/StartWorkerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -132,7 +132,7 @@
 
         // if foreground, we redirect output
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Command/StartScheduledWorkerCommand.php

Spacing +1 added lines, -1 removed lines

@@ -106,7 +106,7 @@
         $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine()));
 
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Controller/DefaultController.php

Spacing +2 added lines, -2 removed lines

@@ -149,7 +149,7 @@ 
     {
         $count = $this->getResque()->retryFailedJobs();
 
-        $this->addFlash('info', 'Retry '.$count.' failed jobs.');
+        $this->addFlash('info', 'Retry ' . $count . ' failed jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }
@@ -161,7 +161,7 @@ 
     {
         $count = $this->getResque()->clearFailedJobs();
 
-        $this->addFlash('info', 'Clear '.$count.' failed jobs.');
+        $this->addFlash('info', 'Clear ' . $count . ' failed jobs.');
 
         return $this->redirectToRoute('ResqueBundle_homepage');
     }

Resque.php

Spacing +1 added lines, -1 removed lines

@@ -251,7 +251,7 @@
      */
     public function getRunningWorkers()
     {
-        return array_filter($this->getWorkers(), function (Worker $worker) {
+        return array_filter($this->getWorkers(), function(Worker $worker) {
             return $worker->getCurrentJob() !== null;
         });
     }