CMProductions / queues

src/Cmp/Queue/Infrastructure/RabbitMQ/AMQPLazyConnectionSingleton.php

Doc Comments +6 added lines

@@ -9,6 +9,12 @@
 
     private static $amqpLazyConnection;
 
+    /**
+     * @param string $host
+     * @param string $port
+     * @param string $user
+     * @param string $password
+     */
     public static function getInstance($host, $port, $user, $password, $vhost = '/')
     {
         if(null === static::$amqpLazyConnection) {

src/Cmp/Queue/Infrastructure/RabbitMQ/RabbitMQReader.php

Doc Comments +3 added lines

@@ -51,6 +51,9 @@
         $this->channel->wait();
     }
 
+    /**
+     * @param callable $callback
+     */
     private function initialize($callback)
     {
         $this->rabbitMQMessageHandler->setEventCallback($callback);