WillRy / rabbitrun

src/Queue/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -115,7 +115,7 @@ 
         $this->validateExecuteCallback();
         
 
-        $this->loopConnection(function () use ($sleepSeconds, $queueName) {
+        $this->loopConnection(function() use ($sleepSeconds, $queueName) {
 
             $this->createQueue($queueName);
 
@@ -128,7 +128,7 @@ 
                 false,
                 false,
                 false,
-                function (AMQPMessage $message) {
+                function(AMQPMessage $message) {
                     pcntl_sigprocmask(SIG_BLOCK, [SIGTERM, SIGINT]);
 
                     $incomeData = json_decode($message->getBody(), true);