puzzle-org / amqp

src/Messages/Message.php

Doc Comments +9 added lines

@@ -27,6 +27,9 @@ 
         $this->changeRoutingKey($routingKey);
     }
 
+    /**
+     * @param string $routingKey
+     */
     public function changeRoutingKey($routingKey)
     {
         $this->setAttribute('routing_key', $routingKey);
@@ -160,6 +163,9 @@ 
         return $this->headers;
     }
 
+    /**
+     * @param string $attributeName
+     */
     public function setAttribute($attributeName, $value)
     {
         if($attributeName !== 'headers')
@@ -180,6 +186,9 @@ 
         return $attributes['headers'];
     }
 
+    /**
+     * @param string $attributeName
+     */
     public function getAttribute($attributeName)
     {
         if(array_key_exists($attributeName, $this->attributes))

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

Doc Comments +12 added lines

@@ -55,11 +55,17 @@ 
         return $this;
     }
     
+    /**
+     * @param integer $level
+     */
     private function isCompressionLevelValid($level)
     {
         return is_numeric($level) && $level >= -1 && $level <= 9;
     }
     
+    /**
+     * @param string $message
+     */
     private function logWarning($message)
     {
         $this->logger->warning(sprintf(
@@ -98,6 +104,9 @@ 
         $this->updateCompressedMessage($message, $compressedContent);
     }
     
+    /**
+     * @param string $compressedContent
+     */
     private function updateCompressedMessage(WritableMessage $message, $compressedContent)
     {
         $message->addHeaders([
@@ -134,6 +143,9 @@ 
         return false;
     }
     
+    /**
+     * @param string $uncompressedContent
+     */
     private function updateUncompressedMessage(ReadableMessage $message, $uncompressedContent)
     {
         $builder = new ReadableMessageModifier($message);