puzzle-org / amqp

src/Silex/AmqpServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -20,30 +20,30 @@
 
     private function registerAmqpServices(Container $app)
     {
-        $app['amqp.client'] = function ($c) {
+        $app['amqp.client'] = function($c) {
             return new Pecl($c['configuration']);
         };
 
-        $app['amqp.workerProvider'] = function ($c) {
+        $app['amqp.workerProvider'] = function($c) {
             return new Pimple($c);
         };
     }
 
     private function registerConsumers(Container $app)
     {
-        $app['amqp.consumers.simple'] = function () {
+        $app['amqp.consumers.simple'] = function() {
             return new Consumers\Simple();
         };
 
-        $app['amqp.consumers.insomniac'] = function () {
+        $app['amqp.consumers.insomniac'] = function() {
             return new Consumers\Insomniac();
         };
 
-        $app['amqp.consumers.retry'] = $app->protect(function (Container $c, $retries = null) {
+        $app['amqp.consumers.retry'] = $app->protect(function(Container $c, $retries = null) {
             return new Consumers\Retry($retries);
         });
 
-        $app['amqp.consumers.instantRetry'] = $app->protect(function (Container $c, $retries, $delayInSeconds) {
+        $app['amqp.consumers.instantRetry'] = $app->protect(function(Container $c, $retries, $delayInSeconds) {
             return new Consumers\InstantRetry($retries, $delayInSeconds);
         });
     }

src/Commands/GenerateSupervisorConfigurationFiles.php

Spacing +5 added lines, -5 removed lines

@@ -78,7 +78,7 @@ 
     {
         $value = $input->getOption($name);
 
-        if(! in_array($value, ['true', 'false']))
+        if (!in_array($value, ['true', 'false']))
         {
             throw new \InvalidArgumentException(sprintf('Invalid value "%s" for option %s, expecting boolean.', $value, $name));
         }
@@ -89,13 +89,13 @@ 
     private function checkRequirements(InputInterface $input)
     {
         $destination = $input->getOption('destination');
-        if(empty($destination))
+        if (empty($destination))
         {
             throw new \InvalidArgumentException('The option --destination is required.');
         }
 
         $server = $input->getOption('server');
-        if(empty($server))
+        if (empty($server))
         {
             throw new \InvalidArgumentException('The option --server is required.');
         }
@@ -105,7 +105,7 @@ 
     {
         $destination = $this->enforceEndingSlash($input->getOption('destination'));
 
-        if( ! $input->getOption('quiet'))
+        if (!$input->getOption('quiet'))
         {
             $output->writeln(sprintf('<info>Destination : <comment>%s</comment></info>', $destination));
         }
@@ -117,7 +117,7 @@ 
     {
         $server = $input->getOption('server');
 
-        if( ! $input->getOption('quiet'))
+        if (!$input->getOption('quiet'))
         {
             $output->writeln(sprintf('<info>Server : <comment>%s</comment></info>', $server));
         }

src/Commands/Worker/Run.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
         $workerName = $input->getArgument('task');
         $workerContext = $this->workerProvider->getWorker($workerName);
 
-        if($workerContext instanceof WorkerContext)
+        if ($workerContext instanceof WorkerContext)
         {
             $output->writeln("Launching <info>$workerName</info>");
 

src/Commands/Worker/ListAll.php

Indentation +6 added lines, -6 removed lines

@@ -25,12 +25,12 @@
     protected function configure()
     {
         $this->setName('list')
-             ->addArgument(
-                  'workerNamePattern',
-                  InputArgument::OPTIONAL,
-                  'Regex pattern of the worker name',
-                  null
-             )
+                ->addArgument(
+                    'workerNamePattern',
+                    InputArgument::OPTIONAL,
+                    'Regex pattern of the worker name',
+                    null
+                )
             ->setDescription('List AMQP workers');
     }
 

Spacing +3 added lines, -3 removed lines

@@ -38,7 +38,7 @@ 
     {
         $workerNamePattern = $input->getArgument('workerNamePattern');
 
-        if(!empty($workerNamePattern))
+        if (!empty($workerNamePattern))
         {
             $comment = sprintf('List of worker with following pattern: %s', $workerNamePattern);
             $services = $this->workerProvider->listWithRegexFilter($workerNamePattern);
@@ -51,7 +51,7 @@ 
 
         $output->writeln(sprintf('<comment>%s</comment>', $comment));
 
-        if(empty($services) || !is_array($services))
+        if (empty($services) || !is_array($services))
         {
             $output->writeln('<error>No worker found</error>');
             return;
@@ -64,7 +64,7 @@ 
         $style = new OutputFormatterStyle('cyan', null, array());
         $output->getFormatter()->setStyle('queue', $style);
 
-        foreach($services as $name => $info)
+        foreach ($services as $name => $info)
         {
             $output->writeln(sprintf(
                 "<info> %s</info>%s\n\t<queue>--> %s</queue>\n",

Braces +1 added lines, -2 removed lines

@@ -42,8 +42,7 @@
         {
             $comment = sprintf('List of worker with following pattern: %s', $workerNamePattern);
             $services = $this->workerProvider->listWithRegexFilter($workerNamePattern);
-        }
-        else
+        } else
         {
             $comment = 'List of all workers';
             $services = $this->workerProvider->listAll();