Evaneos / Burrow

src/Driver/PhpAmqpLibDriver.php

Doc Comments +5 added lines, -2 removed lines

@@ -253,7 +253,7 @@ 
     }
 
     /**
-     * @param $timeout
+     * @param integer $timeout
      *
      * @throws Exception
      */
@@ -302,7 +302,7 @@ 
     /**
      * @param AMQPMessage $message
      *
-     * @return array
+     * @return string[]
      *
      * @throws \OutOfBoundsException
      */
@@ -338,6 +338,9 @@ 
             $message->get(self::REPLY_TO) : '';
     }
 
+    /**
+     * @param string $exchangeName
+     */
     private function retryPublish($exchangeName, Message $message)
     {
         $this->retryPublish = true;

Spacing +3 added lines, -3 removed lines

@@ -64,7 +64,7 @@ 
         $durable = ($type === self::QUEUE_DURABLE);
         $exclusive = ($type === self::QUEUE_EXCLUSIVE);
 
-        list($name, ,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
+        list($name,,) = $this->getChannel()->queue_declare($queueName, false, $durable, $exclusive, false);
 
         return $name;
     }
@@ -79,7 +79,7 @@ 
      */
     public function declareExchange($exchangeName = '', $type = self::EXCHANGE_TYPE_FANOUT)
     {
-        list($name, ,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
+        list($name,,) = $this->getChannel()->exchange_declare($exchangeName, $type, false, true, false);
 
         return $name;
     }
@@ -181,7 +181,7 @@ 
             $autoAck,
             false,
             false,
-            function (AMQPMessage $message) use ($callback, $queueName) {
+            function(AMQPMessage $message) use ($callback, $queueName) {
                 $burrowMessage = new Message(
                     $message->getBody(),
                     '', // Impossible to retrieve here