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

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

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