puzzle-org / amqp

features/bootstrap/ConsumeContext.php

Doc Comments +6 added lines

@@ -103,6 +103,9 @@ 
         $this->theMessageIs(self::JSON_ROUTING_KEY, ContentType::JSON);
     }
     
+    /**
+     * @param string $routingKey
+     */
     private function theMessageIs($routingKey, $contentType)
     {
         $firstMessage = $this->consumedMessages[0];
@@ -145,6 +148,9 @@ 
         $this->oneOfTheMessagesIs(ContentType::JSON, self::JSON_ROUTING_KEY);
     }
     
+    /**
+     * @param string $routingKey
+     */
     private function oneOfTheMessagesIs($contentType, $routingKey)
     {
         $found = null;

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);
             }

src/Consumers/Retry.php

Spacing +1 added lines, -1 removed lines

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

src/Workers/ReadableMessageModifier.php

Spacing +1 added lines, -1 removed lines

@@ -19,7 +19,7 @@
     {
         $this->originalMessage = $originalMessage;
         
-        $this->newRoutingKey= $originalMessage->getRoutingKey();
+        $this->newRoutingKey = $originalMessage->getRoutingKey();
         $this->newBody = null;
         
         $this->newAttributeValues = [];

src/Messages/Bodies/Text.php

Spacing +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     
     public function changeText($text)
     {
-        if(! $this->isConvertibleToString($text))
+        if( ! $this->isConvertibleToString($text))
         {
             throw new \LogicException('Body of type Text must be string convertible.');
         }

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);
         }