puzzle-org / amqp

src/Clients/InMemory.php

Unused Use Statements -2 removed lines

@@ -4,9 +4,7 @@
 
 use Puzzle\AMQP\Client;
 use Puzzle\AMQP\WritableMessage;
-use Puzzle\AMQP\Messages\InMemoryJson;
 use Psr\Log\NullLogger;
-use Puzzle\AMQP\Collections;
 
 class InMemory implements Client
 {

src/Clients/Pecl.php

Unused Use Statements -3 removed lines

@@ -4,14 +4,11 @@
 
 use Puzzle\Configuration;
 use Puzzle\PrefixedConfiguration;
-
 use Puzzle\AMQP\Client;
-use Puzzle\AMQP\Messages;
 use Puzzle\AMQP\Workers\MessageAdapter;
 use Psr\Log\LoggerAwareTrait;
 use Psr\Log\NullLogger;
 use Puzzle\AMQP\WritableMessage;
-use Puzzle\AMQP\Collections;
 
 class Pecl implements Client
 {

Spacing +3 added lines, -3 removed lines

@@ -32,7 +32,7 @@ 
 
     private function ensureIsConnected()
     {
-        if(! $this->channel instanceof \AMQPChannel)
+        if (!$this->channel instanceof \AMQPChannel)
         {
             $configuration = new PrefixedConfiguration($this->configuration, 'amqp/broker');
 
@@ -43,7 +43,7 @@ 
             $connection->setPassword($configuration->readRequired('password'));
 
             $vhost = $configuration->read('vhost', null);
-            if($vhost !== null)
+            if ($vhost !== null)
             {
                 $connection->setVhost($vhost);
             }
@@ -110,7 +110,7 @@ 
 
         $ex = new \AMQPExchange($this->channel);
 
-        if(!empty($exchangeName))
+        if (!empty($exchangeName))
         {
             $ex->setName($exchangeName);
             $ex->setType($type);

Braces +2 added lines, -4 removed lines

@@ -60,8 +60,7 @@ 
         try
         {
             $ex = $this->getExchange($exchangeName);
-        }
-        catch (\Exception $e)
+        } catch (\Exception $e)
         {
             $this->logMessage($exchangeName, $message);
 
@@ -93,8 +92,7 @@ 
                 $message->getFlags(),
                 $message->packAttributes()
             );
-        }
-        catch (\Exception $e)
+        } catch (\Exception $e)
         {
             $this->logMessage($ex->getName(), $message);
 

src/Services/SupervisorConfigurationGenerator.php

Doc Comments +6 added lines

@@ -19,6 +19,12 @@
         $this->overwrite = true;
     }
 
+    /**
+     * @param boolean $autostart
+     * @param boolean $autorestart
+     * @param string $appId
+     * @param string $destination
+     */
     public function generate(array $workers, $autostart, $autorestart, $server, $appId, $destination, OutputInterface $output)
     {
         foreach($workers as $worker => $data)

Spacing +4 added lines, -4 removed lines

@@ -21,14 +21,14 @@ 
 
     public function generate(array $workers, $autostart, $autorestart, $server, $appId, $destination, OutputInterface $output)
     {
-        foreach($workers as $worker => $data)
+        foreach ($workers as $worker => $data)
         {
-            if( ! $data['isDeploymentAllowed'])
+            if (!$data['isDeploymentAllowed'])
             {
                 continue;
             }
 
-            if( ! in_array($server, $data['servers']))
+            if (!in_array($server, $data['servers']))
             {
                 continue;
             }
@@ -45,7 +45,7 @@ 
         $this->filesystem->write($filename, $configuration, $this->overwrite);
 
         $message = sprintf('%s', $destination . $filename);
-        if($output->getVerbosity() >= OutputInterface::VERBOSITY_VERBOSE)
+        if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERBOSE)
         {
             $message = sprintf("<comment>%s%s</comment>\n%s\n", $destination, $filename, $configuration);
         }

src/Messages/Raw.php

Spacing +12 added lines, -12 removed lines

@@ -73,7 +73,7 @@ 
 
     public function setBody($body)
     {
-        if(! is_array($body))
+        if (!is_array($body))
         {
             $body = array($body);
         }
@@ -104,7 +104,7 @@ 
 
     public function addHeaders(array $headers)
     {
-        foreach($headers as $name => $value)
+        foreach ($headers as $name => $value)
         {
             $this->addHeader($name, $value);
         }
@@ -121,14 +121,14 @@ 
 
     public function packAttributes($timestamp = false)
     {
-        if($timestamp === false)
+        if ($timestamp === false)
         {
             $timestamp = (new \DateTime("now"))->getTimestamp();
         }
 
-        return array_map(function ($value) use($timestamp) {
+        return array_map(function($value) use($timestamp) {
 
-            if($value instanceof \Closure)
+            if ($value instanceof \Closure)
             {
                 $value = $value($timestamp);
             }
@@ -147,9 +147,9 @@ 
 
     public function setAttribute($attributeName, $value)
     {
-        if($attributeName !== 'headers')
+        if ($attributeName !== 'headers')
         {
-            if(array_key_exists($attributeName, $this->attributes))
+            if (array_key_exists($attributeName, $this->attributes))
             {
                 $this->attributes[$attributeName] = $value;
             }
@@ -172,7 +172,7 @@ 
 
     public function getAttribute($attributeName)
     {
-        if(array_key_exists($attributeName, $this->attributes))
+        if (array_key_exists($attributeName, $this->attributes))
         {
             return $this->attributes[$attributeName];
         }
@@ -203,7 +203,7 @@ 
     {
         $routingKey = $readableMessage->getRoutingKey();
 
-        if($newRoutingKey !== false)
+        if ($newRoutingKey !== false)
         {
             $routingKey = $newRoutingKey;
         }
@@ -211,7 +211,7 @@ 
         $writableMessage = new static($routingKey);
 
         $decodedBody = $readableMessage->getDecodedBody();
-        if(! is_array($decodedBody))
+        if (!is_array($decodedBody))
         {
             $decodedBody = array($decodedBody);
         }
@@ -222,9 +222,9 @@ 
 
         $attributes = $readableMessage->getAttributes();
         $skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key');
-        foreach($attributes as $attributeName => $value)
+        foreach ($attributes as $attributeName => $value)
         {
-            if(! in_array($attributeName, $skippedAttributes))
+            if (!in_array($attributeName, $skippedAttributes))
             {
                 $writableMessage->setAttribute($attributeName, $value);
             }

src/Workers/Providers/Pimple.php

Spacing +4 added lines, -4 removed lines

@@ -23,12 +23,12 @@ 
         $workerContext = null;
         $key = $this->computeWorkerServiceKey($workerName);
 
-        if(isset($this->container[$key]))
+        if (isset($this->container[$key]))
         {
             $workerContext = $this->container[$key];
         }
         
-        if(isset($this->container[self::MESSAGE_HOOKS_DIC_KEY]))
+        if (isset($this->container[self::MESSAGE_HOOKS_DIC_KEY]))
         {
             $workerContext->setMessageHooks($this->container[self::MESSAGE_HOOKS_DIC_KEY]);
         }
@@ -64,12 +64,12 @@ 
     {
         $workers = array();
         
-        foreach($extractedWorkers as $worker)
+        foreach ($extractedWorkers as $worker)
         {
             $key = $this->formatWorkerName($worker);
             $worker = $this->container[$worker];
         
-            if($worker instanceof WorkerContext)
+            if ($worker instanceof WorkerContext)
             {
                 $workers[$key] = [
                     'queue' => $worker->getQueue(),

src/Workers/WorkerContext.php

Spacing +4 added lines, -4 removed lines

@@ -42,7 +42,7 @@ 
 
     public function getWorker()
     {
-        if($this->worker instanceof \Closure)
+        if ($this->worker instanceof \Closure)
         {
             $closure = $this->worker;
             $this->worker = $closure();
@@ -99,7 +99,7 @@ 
     
     public function deployInstances($numberOfInstance)
     {
-        if(! empty($numberOfInstance))
+        if (!empty($numberOfInstance))
         {
             $this->instances = (int) $numberOfInstance;
         }
@@ -114,9 +114,9 @@ 
     
     public function deployOn($servers)
     {
-        if(! empty($servers))
+        if (!empty($servers))
         {
-            if(! is_array($servers))
+            if (!is_array($servers))
             {
                 $servers = [$servers];
             }

src/Workers/MessageAdapter.php

Spacing +8 added lines, -8 removed lines

@@ -50,7 +50,7 @@ 
         $callable = $this->getFormatterStrategy($this->getContentType());
         $body = $this->getRawBody();
 
-        if($callable instanceof \Closure)
+        if ($callable instanceof \Closure)
         {
             $body = $callable($body);
         }
@@ -65,11 +65,11 @@ 
 
     public function applyHooks(MessageHookCollection $messageHookCollection)
     {
-        if(!empty($messageHookCollection))
+        if (!empty($messageHookCollection))
         {
-            foreach($messageHookCollection as $messageHook)
+            foreach ($messageHookCollection as $messageHook)
             {
-                if($messageHook instanceof MessageHook)
+                if ($messageHook instanceof MessageHook)
                 {
                     $this->decodedBody = $messageHook->process($this->decodedBody);
                 }
@@ -85,7 +85,7 @@ 
     public function getAttribute($attributeName)
     {
         $messageProperties = $this->message->getProperties();
-        if(array_key_exists($attributeName, $messageProperties))
+        if (array_key_exists($attributeName, $messageProperties))
         {
             return $messageProperties[$attributeName];
         }
@@ -101,7 +101,7 @@ 
             },
         );
 
-        if(array_key_exists($contentType, $formatterStrategies) === true)
+        if (array_key_exists($contentType, $formatterStrategies) === true)
         {
             return $formatterStrategies[$contentType];
         }
@@ -134,7 +134,7 @@ 
     private function getHeader($headerName)
     {
         $headers = $this->getHeaders();
-        if(array_key_exists($headerName, $headers))
+        if (array_key_exists($headerName, $headers))
         {
             return $headers[$headerName];
         }
@@ -158,7 +158,7 @@ 
     {
         $headers = $this->getHeaders();
 
-        if(! array_key_exists('routing_key', $headers))
+        if (!array_key_exists('routing_key', $headers))
         {
             return null;
         }

src/Workers/ProcessorInterfaceAdapter.php

Spacing +2 added lines, -2 removed lines

@@ -25,7 +25,7 @@ 
         
         $hooks = $this->workerContext->getMessageHooks();
         
-        if(!empty($hooks))
+        if (!empty($hooks))
         {
             $message->applyHooks($hooks);
         }
@@ -38,7 +38,7 @@ 
         {
             $processResult = $this->workerContext->getWorker()->process($message);
         }
-        catch(\Exception $exception)
+        catch (\Exception $exception)
         {
             $this->onWorkerProcessed();
 

Braces +1 added lines, -2 removed lines

@@ -37,8 +37,7 @@
         try
         {
             $processResult = $this->workerContext->getWorker()->process($message);
-        }
-        catch(\Exception $exception)
+        } catch(\Exception $exception)
         {
             $this->onWorkerProcessed();
 

src/Consumers/InstantRetry.php

Spacing +2 added lines, -2 removed lines

@@ -43,12 +43,12 @@
             'max_execution_time' => self::DEFAULT_MAX_EXECUTION_TIME,
         );
 
-        if(!empty($this->retries))
+        if (!empty($this->retries))
         {
             $options['instant_retry_attempts'] = $this->retries;
         }
 
-        if(!empty($this->delay))
+        if (!empty($this->delay))
         {
             $options['instant_retry_delay'] = $this->delay * 1000000; //computed in microseconds
         }