puzzle-org / amqp

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)

Upper-Lower-Casing +1 added lines, -1 removed lines

@@ -72,7 +72,7 @@
 user=www-data
 autostart=$autostart
 autorestart=$autorestart
-TXT;
+txt;
     }
     
     private function booleanToString($value)

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/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 +2 added lines, -2 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;

src/Clients/Pecl.php

Unused Use Statements -2 removed lines

@@ -6,12 +6,10 @@
 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 +4 added lines, -4 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');
 
@@ -61,7 +61,7 @@ 
         {
             $ex = $this->getExchange($exchangeName);
         }
-        catch (\Exception $e)
+        catch(\Exception $e)
         {
             $this->logMessage($exchangeName, $message);
 
@@ -94,7 +94,7 @@ 
                 $message->packAttributes()
             );
         }
-        catch (\Exception $e)
+        catch(\Exception $e)
         {
             $this->logMessage($ex->getName(), $message);
 
@@ -110,7 +110,7 @@ 
 
         $ex = new \AMQPExchange($this->channel);
 
-        if(!empty($exchangeName))
+        if( ! empty($exchangeName))
         {
             $ex->setName($exchangeName);
             $ex->setType($type);

src/Workers/MessageAdapter.php

Spacing +3 added lines, -3 removed lines

@@ -65,7 +65,7 @@ 
 
     public function applyHooks(MessageHookCollection $messageHookCollection)
     {
-        if(!empty($messageHookCollection))
+        if( ! empty($messageHookCollection))
         {
             foreach($messageHookCollection as $messageHook)
             {
@@ -151,14 +151,14 @@ 
     {
         $retryHeader = $this->getHeader(\Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_HEADER);
 
-        return (!empty($retryHeader) && (int) $retryHeader === $retryOccurence);
+        return ( ! empty($retryHeader) && (int) $retryHeader === $retryOccurence);
     }
 
     public function getRoutingKeyFromHeader()
     {
         $headers = $this->getHeaders();
 
-        if(! array_key_exists('routing_key', $headers))
+        if( ! array_key_exists('routing_key', $headers))
         {
             return null;
         }

src/Workers/ProcessorInterfaceAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
         
         $hooks = $this->workerContext->getMessageHooks();
         
-        if(!empty($hooks))
+        if( ! empty($hooks))
         {
             $message->applyHooks($hooks);
         }

src/Workers/WorkerContext.php

Spacing +3 added lines, -3 removed lines

@@ -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/Messages/InMemoryJson.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     {
         $retryHeader = $this->getHeader(\Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_HEADER);
         
-        return (!empty($retryHeader) && (int) $retryHeader === $retryOccurence);
+        return ( ! empty($retryHeader) && (int) $retryHeader === $retryOccurence);
     }
     
     public function applyHooks(MessageHookCollection $messageHookCollection)

src/Messages/Raw.php

Spacing +4 added lines, -4 removed lines

@@ -73,7 +73,7 @@ 
 
     public function setBody($body)
     {
-        if(! is_array($body))
+        if( ! is_array($body))
         {
             $body = array($body);
         }
@@ -126,7 +126,7 @@ 
             $timestamp = (new \DateTime("now"))->getTimestamp();
         }
 
-        return array_map(function ($value) use($timestamp) {
+        return array_map(function($value) use($timestamp) {
 
             if($value instanceof \Closure)
             {
@@ -211,7 +211,7 @@ 
         $writableMessage = new static($routingKey);
 
         $decodedBody = $readableMessage->getDecodedBody();
-        if(! is_array($decodedBody))
+        if( ! is_array($decodedBody))
         {
             $decodedBody = array($decodedBody);
         }
@@ -224,7 +224,7 @@ 
         $skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key');
         foreach($attributes as $attributeName => $value)
         {
-            if(! in_array($attributeName, $skippedAttributes))
+            if( ! in_array($attributeName, $skippedAttributes))
             {
                 $writableMessage->setAttribute($attributeName, $value);
             }