thecodingmachine / oo-amqp-client

src/Objects/Queue.php

Spacing +1 added lines, -1 removed lines

@@ -539,7 +539,7 @@
                                     $consumer->isNoAck(),
                                     $consumer->isExclusive(),
                                     $consumer->isNoWait(),
-                                    function (AMQPMessage $msg) use ($consumer) {
+                                    function(AMQPMessage $msg) use ($consumer) {
                                         $consumer->callback($msg);
                                     },
                                     $consumer->getTicket(),

src/Client.php

Spacing +1 added lines, -1 removed lines

@@ -196,7 +196,7 @@
      */
     public function getQueues()
     {
-        return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) {
+        return array_filter($this->rabbitMqObjects, function(RabbitMqObjectInterface $object) {
             return $object instanceof QueueInterface;
         });
     }

Indentation +9 added lines, -9 removed lines

@@ -78,17 +78,17 @@ 
     private $rabbitMqObjects = [];
 
     /**
-    * Maximum connection's retry
-    **/
+     * Maximum connection's retry
+     **/
     const MAX_RETRY = 10;
 
     /**
-    * current retry amount
-    **/
+     * current retry amount
+     **/
     private static $retry = 0;
     /**
-    * time in seconds to wait between each retry
-    **/
+     * time in seconds to wait between each retry
+     **/
     const WAIT_TIME = 30;
 
     public function __construct($host, $port, $user, $password)
@@ -180,9 +180,9 @@ 
     }
 
     /**
-    * Function used to create $this->connection
-    * handle connection's retry in case of the rabbitmq server is not ready yet
-    **/
+     * Function used to create $this->connection
+     * handle connection's retry in case of the rabbitmq server is not ready yet
+     **/
     private function createConnection()
     {
         try {