thecodingmachine / oo-amqp-client

src/Objects/Exchange.php

Doc Comments +3 added lines, -1 removed lines

@@ -86,7 +86,6 @@ 
     /**
      * Set the to (Binding).
      *
-     * @param Client $to
      * @param string $name
      * @param string $type direct, topic, headers or fanout
      */
@@ -292,6 +291,9 @@ 
         }
     }
 
+    /**
+     * @param string $routingKey
+     */
     public function publish(Message $message, $routingKey, $mandatory = false,
                             $immediate = false,
                             $ticket = null)

src/Objects/Queue.php

Doc Comments +1 added lines, -2 removed lines

@@ -133,7 +133,6 @@ 
     /**
      * Set the source (Binding).
      *
-     * @param Binding             $source
      * @param string              $name
      * @param ConsumerInterface[] $consumers
      */
@@ -324,7 +323,7 @@ 
     /**
      * Get RabbitMq specific parameter : dead letter queue.
      *
-     * @return Queue
+     * @return Exchange
      */
     public function getDeadLetterExchanger()
     {

src/Client.php

Indentation +5 added lines, -5 removed lines

@@ -178,11 +178,11 @@
                 $this->connection = new AMQPStreamConnection($this->host, $this->port, $this->user, $this->password);
             } catch (\ErrorException $e) {
                 /**
-                * We are trying to catch the exception when the connection if refused
-                **/
-              if (preg_match("/.*unable to connect.*Connection refused.*/", $e->__toString())) {
-                  throw new ConnectionException("Cannot create the connection", 404, $e);
-              }
+                 * We are trying to catch the exception when the connection if refused
+                 **/
+                if (preg_match("/.*unable to connect.*Connection refused.*/", $e->__toString())) {
+                    throw new ConnectionException("Cannot create the connection", 404, $e);
+                }
                 throw $e;
             }
             $this->channel = $this->connection->channel();

tests/ClientTest.php

Indentation +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
         global $rabbitmq_password;
 
         if (!$port) {
-          $port = $rabbitmq_port;
+            $port = $rabbitmq_port;
         }