thecodingmachine / oo-amqp-client

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