metfan / rabbit-setup

src/Metfan/RabbitSetup/Manager/RabbitMq/QueueManager.php

Doc Comments +1 added lines, -1 removed lines

@@ -66,7 +66,7 @@
     /**
      * Delete a queue from a vhost
      *
-     * @param $vhost
+     * @param string $vhost
      * @param $name
      * @return mixed
      */

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
             $options);
         $this->logger->info(sprintf('Create queue: <info>%s</info>', $queueName));
 
-        foreach($bindings as $binding) {
+        foreach ($bindings as $binding) {
             $this->client->query(
                 ClientInterface::METHOD_POST,
                 sprintf('/api/bindings/%s/e/%s/q/%s', $this->vhost, $binding['exchange'], $queueName),

src/Metfan/RabbitSetup/Command/ValidateExpertCommand.php

Indentation +2 added lines, -2 removed lines

@@ -40,8 +40,8 @@
     protected function execute(InputInterface $input, OutputInterface $output)
     {
         /**
-        * set context inside container
-        */
+         * set context inside container
+         */
         $this->container->register(new LoggerProvider($output));
 
         $parser = new ParseExpertConfig();

src/Metfan/RabbitSetup/Configuration/ConfigExpertConfiguration.php

Spacing +8 added lines, -8 removed lines

@@ -22,7 +22,7 @@ 
         $rootNode
             ->validate()
                 ->always()
-                ->then(function($v){
+                ->then(function($v) {
                     /**
                      * ensure that connections are correctly declared between vhosts and connection
                      */
@@ -57,7 +57,7 @@ 
                     ->useAttributeAsKey('name')
                     ->prototype('array')
                         ->validate()
-                            ->ifTrue(function($v){ return count($v['queues']) > 0;})
+                            ->ifTrue(function($v) { return count($v['queues']) > 0; })
                             ->then(function($v) {
                                 foreach ($v['queues'] as $name => $config) {
                                     if (isset($config['bindings'])) {
@@ -107,8 +107,8 @@ 
 
         $node
             ->validate()
-                ->ifTrue(function($v) {return isset($v['federation-upstream-set']);})
-                ->then(function($v){
+                ->ifTrue(function($v) {return isset($v['federation-upstream-set']); })
+                ->then(function($v) {
                     /**
                      * Verify all server name use in federation-upstream-set
                      * were declared in federation-upstream
@@ -143,10 +143,10 @@ 
                             ->scalarNode('expires')
                                 ->validate()
                                 ->always()
-                                    ->then(function($value){
+                                    ->then(function($value) {
                                         if (!$value) {
                                             return null;
-                                        } elseif (is_int($value)){
+                                        } elseif (is_int($value)) {
                                             return (int) $value;
                                         }
 
@@ -161,10 +161,10 @@ 
                             ->scalarNode('message-ttl')
                                 ->validate()
                                 ->always()
-                                    ->then(function($value){
+                                    ->then(function($value) {
                                         if (!$value) {
                                             return null;
-                                        } elseif (is_int($value)){
+                                        } elseif (is_int($value)) {
                                             return (int) $value;
                                         }
 

src/Metfan/RabbitSetup/Container/LoggerProvider.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
     public function register(Container $container)
     {
         $container['command_output'] = $this->output;
-        $container['logger'] = function($c){
+        $container['logger'] = function($c) {
             return new ConsoleLogger(
                 $c['command_output'],
                 [LogLevel::INFO => OutputInterface::VERBOSITY_NORMAL],

src/Metfan/RabbitSetup/Http/CurlClient.php

Spacing +2 added lines, -2 removed lines

@@ -55,8 +55,8 @@
             $this->setMethodOption($method)
         );
 
-        if (ClientInterface::METHOD_GET !==$method
-            && ClientInterface::METHOD_DELETE !==$method
+        if (ClientInterface::METHOD_GET !== $method
+            && ClientInterface::METHOD_DELETE !== $method
             && !empty($parameters)) {
             $options['CURLOPT_POSTFIELDS'] = json_encode($parameters);
         }

src/Metfan/RabbitSetup/Manager/Command/DeleteManager.php

Spacing +3 added lines, -3 removed lines

@@ -64,7 +64,7 @@ 
         } else {
             //few queues to delete, let stack them in array
             $queues = explode(',', $queues);
-            array_walk($queues, function(&$item, $key, $vhost){
+            array_walk($queues, function(&$item, $key, $vhost) {
                 $item = ['vhost' => $vhost, 'name' => trim($item)];
             }, $vhost);
         }
@@ -101,7 +101,7 @@ 
         } else {
             //few exchanges to delete, let stack them in array
             $exchanges = explode(',', $exchanges);
-            array_walk($exchanges, function(&$item, $key, $vhost){
+            array_walk($exchanges, function(&$item, $key, $vhost) {
                 $item = ['vhost' => $vhost, 'name' => trim($item)];
             }, $vhost);
         }
@@ -128,7 +128,7 @@ 
         } else {
             //few policies to delete, let stack them in array
             $policies = explode(',', $policies);
-            array_walk($policies, function(&$item, $key, $vhost){
+            array_walk($policies, function(&$item, $key, $vhost) {
                 $item = ['vhost' => $vhost, 'name' => trim($item)];
             }, $vhost);
         }