puzzle-org / amqp

src/Messages/Chunks/ChunkedMessageMetadata.php

Spacing +1 added lines, -1 removed lines

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

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

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

features/bootstrap/SendContext.php

Doc Comments +6 added lines

@@ -123,6 +123,9 @@ 
         \PHPUnit_Framework_Assert::assertSame(ContentType::TEXT, $headers[Gzip::HEADER_COMPRESSION_CONTENT_TYPE]);
     }
     
+    /**
+     * @param string $routingKey
+     */
     private function theMessageInQueueContains($routingKey, $content, $queueName, $contentType)
     {
         $messages = $this->api->getMessagesFromQueue($this->vhost(), $queueName);
@@ -139,6 +142,9 @@ 
         return $message;
     }
     
+    /**
+     * @param integer $expectedNbMessages
+     */
     private function assertMessagesInQueue($queue, $expectedNbMessages, $waitingSeconds = 11)
     {
         $nbMessages = $this->nbMessagesInQueue($queue);