puzzle-org / amqp

src/Services/SupervisorConfigurationGenerator.php

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/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/InMemory.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
      */
     public static function build($routingKey, Body $body = null, array $additionalHeaders = [], array $additionalAttributes = [])
     {
-        if(! $body instanceof Body)
+        if( ! $body instanceof Body)
         {
             $body = new NullBody();
         }

src/Clients/Decorators/PrefixedQueuesClient.php

Spacing +1 added lines, -1 removed lines

@@ -44,7 +44,7 @@
     {
         $queueNameParts = [];
 
-        if(! empty($this->queueNamePrefix))
+        if( ! empty($this->queueNamePrefix))
         {
             $queueNameParts[] = trim($this->queueNamePrefix);
         }

src/Workers/MessageAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -109,7 +109,7 @@
         $skippedAttributes = array('timestamp', 'headers', 'app_id', 'routing_key');
         foreach($attributes as $attributeName => $value)
         {
-            if(! in_array($attributeName, $skippedAttributes))
+            if( ! in_array($attributeName, $skippedAttributes))
             {
                 $writable->setAttribute($attributeName, $value);
             }

Braces +2 added lines, -1 removed lines

@@ -69,7 +69,8 @@
 
     public function __toString(): string
     {
-        try {
+        try
+        {
             return Json::encode([
                 'routing_key' => $this->getRoutingKey(),
                 'body' => (string) $this->body,

src/Messages/Processors/AddHeader.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
         
         foreach($this->headers as $header => $value)
         {
-            if(! isset($alreadySetHeaders[$header]))
+            if( ! isset($alreadySetHeaders[$header]))
             {
                 $message->addHeader($header, $value);
             }