puzzle-org / amqp

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
         }

src/Consumers/Retry.php

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
             'retry_key_pattern' => sprintf(self::RETRY_ROUTING_KEY_PATTERN, $workerContext->queue),
         );
 
-        if(! empty($this->retries))
+        if( ! empty($this->retries))
         {
             $options['retry_attempts'] = $this->retries;
         }

src/Commands/Worker/ListAll.php

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/Commands/GenerateSupervisorConfigurationFiles.php

Spacing +1 added lines, -1 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));
         }

src/Clients/Decorators/PrefixedExchangesClient.php

Spacing +1 added lines, -1 removed lines

@@ -35,7 +35,7 @@
     {
         $exchangeParts = [];
         
-        if(! empty($this->exchangesPrefix))
+        if( ! empty($this->exchangesPrefix))
         {
             $exchangeParts[] = trim($this->exchangesPrefix);
         }

src/Clients/Pecl.php

Spacing +2 added lines, -2 removed lines

@@ -30,7 +30,7 @@ 
 
     private function ensureIsConnected()
     {
-        if(! $this->channel instanceof \AMQPChannel)
+        if( ! $this->channel instanceof \AMQPChannel)
         {
             $configuration = new PrefixedConfiguration($this->configuration, 'amqp/broker');
 
@@ -108,7 +108,7 @@ 
 
         $ex = new \AMQPExchange($this->channel);
 
-        if(!empty($exchangeName))
+        if( ! empty($exchangeName))
         {
             $ex->setName($exchangeName);
             $ex->setType($type);

src/Messages/Bodies/Json.php

Spacing +1 added lines, -1 removed lines

@@ -32,7 +32,7 @@
     
     public function changeContent($content)
     {
-        if(! is_array($content))
+        if( ! is_array($content))
         {
             $content = array($content);
         }

src/Messages/Bodies/Text.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
     
     public function changeText($text)
     {
-        if(! is_array($text))
+        if( ! is_array($text))
         {
             $text = array($text);
         }

src/Messages/Message.php

Spacing +1 added lines, -1 removed lines

@@ -218,7 +218,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);
             }