puzzle-org / amqp

src/Messages/Processors/GZip.php

Spacing +3 added lines, -3 removed lines

@@ -36,7 +36,7 @@ 
         $this->encodingMode = FORCE_GZIP;
         $this->logger = new NullLogger();
         
-        if(! $bodyFactory instanceof BodyFactory)
+        if( ! $bodyFactory instanceof BodyFactory)
         {
             $bodyFactory = new Standard();
         }
@@ -48,7 +48,7 @@ 
      */
     public function setCompressionLevel($compressionLevel = -1)
     {
-        if(! $this->isCompressionLevelValid($compressionLevel))
+        if( ! $this->isCompressionLevelValid($compressionLevel))
         {
             $this->logWarning(sprintf(
                 "Invalid compression level (%s)",
@@ -79,7 +79,7 @@ 
     
     public function setEncodingMode($mode)
     {
-        if(! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE]))
+        if( ! is_scalar($mode) || ! in_array($mode, [FORCE_GZIP, FORCE_DEFLATE]))
         {
             $this->logWarning(sprintf(
                 "Invalid encoding mode (%s)",

src/Workers/MessageAdapterFactory.php

Spacing +1 added lines, -1 removed lines

@@ -12,7 +12,7 @@
 
     public function __construct(BodyFactory $bodyFactory = null)
     {
-        if(! $bodyFactory instanceof BodyFactory)
+        if( ! $bodyFactory instanceof BodyFactory)
         {
             $bodyFactory = new Standard();
         }

src/Workers/MessageAdapterFactoryAware.php

Spacing +1 added lines, -1 removed lines

@@ -18,7 +18,7 @@
     {
         $factory = $this->messageAdapterFactory;
         
-        if(! $factory instanceof MessageAdapterFactory)
+        if( ! $factory instanceof MessageAdapterFactory)
         {
             $factory = new MessageAdapterFactory();
         }

src/Clients/ChunkedMessageClient.php

Spacing +2 added lines, -2 removed lines

@@ -20,7 +20,7 @@ 
     {
         $this->changeRoutingKeyPrefix(self::DEFAULT_ROUTING_KEY_PREFIX);
 
-        if(! $memory instanceof MemoryManagementStrategy)
+        if( ! $memory instanceof MemoryManagementStrategy)
         {
             $memory = new NullMemoryManagementStrategy();
         }
@@ -43,7 +43,7 @@ 
     {
         $streamedContent = $chunkedMessage->getBodyInTransportFormat();
 
-        if(! $streamedContent instanceof \Generator)
+        if( ! $streamedContent instanceof \Generator)
         {
             return $this->client->publish($exchangeName, $chunkedMessage);
         }

src/Messages/Bodies/StreamedFile.php

Spacing +1 added lines, -1 removed lines

@@ -52,7 +52,7 @@
 
         $stream = fopen($this->filepath, 'r');
 
-        while(! feof($stream))
+        while( ! feof($stream))
         {
             $content = fread($stream, $this->chunkSize->toBytes());
             $playhead++;

src/Messages/Chunks/ChunkedMessageMetadata.php

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

@@ -28,7 +28,7 @@
         {
             if(! isset($headers[$key]))
             {
-                throw new \InvalidArgumentException("Missing $key in chunked message metadata");
+                throw new \InvalidArgumentException("missing $key in chunked message metadata");
             }
         }
 

Spacing +3 added lines, -3 removed lines

@@ -15,9 +15,9 @@ 
     private string
         $checksum;
 
-    public function __construct(string|Uuid $uuid, int $size, int $nbChunks, string $checksum)
+    public function __construct(string | Uuid $uuid, int $size, int $nbChunks, string $checksum)
     {
-        if(! $uuid instanceof Uuid)
+        if( ! $uuid instanceof Uuid)
         {
             $uuid = new Uuid($uuid);
         }
@@ -34,7 +34,7 @@ 
 
         foreach($requiredKeys as $key)
         {
-            if(! isset($headers[$key]))
+            if( ! isset($headers[$key]))
             {
                 throw new \InvalidArgumentException("Missing $key in chunked message metadata");
             }

src/Messages/Chunks/ChunkMetadata.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
 
         foreach($requiredKeys as $key)
         {
-            if(! isset($headers[$key]))
+            if( ! isset($headers[$key]))
             {
                 throw new \InvalidArgumentException("Missing $key in chunk metadata");
             }

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

@@ -24,7 +24,7 @@
         {
             if(! isset($headers[$key]))
             {
-                throw new \InvalidArgumentException("Missing $key in chunk metadata");
+                throw new \InvalidArgumentException("missing $key in chunk metadata");
             }
         }
 

src/Workers/WorkerContext.php

Spacing +1 added lines, -1 removed lines

@@ -1,6 +1,6 @@
 <?php
 
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace Puzzle\AMQP\Workers;
 

src/Consumers/InstantRetry.php

Spacing +2 added lines, -2 removed lines

@@ -41,12 +41,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
         }