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

tests/ClientTest.php

Spacing +1 added lines, -1 removed lines

@@ -161,7 +161,7 @@
     {
         $client = $this->makeClient();
         $queue = new Queue($client, 'test_direct_queue', [
-            new Consumer(function (AMQPMessage $msg) {
+            new Consumer(function(AMQPMessage $msg) {
                 $this->msgReceived = $msg;
             }, new NullLogger())
         ]);