portiny / rabbitmq

src/Consumer/AbstractConsumer.php

Doc Comments +5 added lines

@@ -33,6 +33,7 @@ 
 	private $consumedMessages = 0;
 
 	/**
+	 * @param integer $numberOfMessages
 	 * @return MethodBasicConsumeOkFrame|PromiseInterface
 	 */
 	final public function consume(Channel $channel, ?int $numberOfMessages = null)
@@ -40,6 +41,10 @@ 
 		$channel->qos($this->getPrefetchSize(), $this->getPrefetchCount());
 
 		return $channel->consume(
+
+			/**
+			 * @param integer $channel
+			 */
 			function (Message $message, Channel $channel, $client) use ($numberOfMessages): void {
 				$result = $this->process($message);