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;

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