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

src/Clients/Pecl.php

Doc Comments +3 added lines

@@ -69,6 +69,9 @@
         }
     }
 
+    /**
+     * @param string $exchangeName
+     */
     public function publish($exchangeName, WritableMessage $message)
     {
         if($message->isChunked())

src/Messages/Bodies/StreamedFile.php

Doc Comments +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
     }
 
     /**
-     * @return \Generator|string
+     * @return \Generator
      */
     public function asTransported()
     {