WillRy / rabbitrun

src/Queue/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -118,7 +118,7 @@ 
             throw new \Exception("Define a onExecuting callback");
         }
 
-        $this->loopConnection(function () use ($sleepSeconds, $queueName) {
+        $this->loopConnection(function() use ($sleepSeconds, $queueName) {
 
             $this->createQueue($queueName);
 
@@ -131,7 +131,7 @@ 
                 false,
                 false,
                 false,
-                function (AMQPMessage $message) {
+                function(AMQPMessage $message) {
                     pcntl_sigprocmask(SIG_BLOCK, [SIGTERM, SIGINT]);