WillRy / rabbitrun

src/Base.php

Spacing +5 added lines, -5 removed lines

@@ -31,10 +31,10 @@ 
          * Faz a execucao parar ao enviar um sinal do linux para matar o script
          */
         if (php_sapi_name() == "cli") {
-            \pcntl_signal(SIGTERM, function ($signal) {
+            \pcntl_signal(SIGTERM, function($signal) {
                 $this->shutdown($signal);
             }, false);
-            \pcntl_signal(SIGINT, function ($signal) {
+            \pcntl_signal(SIGINT, function($signal) {
                 $this->shutdown($signal);
             }, false);
         }
@@ -56,10 +56,10 @@ 
                 print "Caught SIGTERM {$data}" . PHP_EOL;
                 exit;
             case SIGKILL:
-                print "Caught SIGKILL {$data}" . PHP_EOL;;
+                print "Caught SIGKILL {$data}" . PHP_EOL; ;
                 exit;
             case SIGINT:
-                print "Caught SIGINT {$data}" . PHP_EOL;;
+                print "Caught SIGINT {$data}" . PHP_EOL; ;
                 exit;
         }
     }
@@ -206,7 +206,7 @@ 
                 $this->getConnection(true);
                 $callback();
             } catch (\Exception $e) {
-                echo get_class($e).':' . $e->getMessage() . " | file:" . $e->getFile() . " | line:" . $e->getLine() . PHP_EOL;
+                echo get_class($e) . ':' . $e->getMessage() . " | file:" . $e->getFile() . " | line:" . $e->getLine() . PHP_EOL;
                 $this->cleanConnection();
                 sleep(2);
             }

src/PubSub/PubSub.php

Spacing +2 added lines, -2 removed lines

@@ -109,7 +109,7 @@ 
         int    $sleepSeconds = 3
     ) {
 
-        $this->loopConnection(function () use ($sleepSeconds, $queueName) {
+        $this->loopConnection(function() use ($sleepSeconds, $queueName) {
 
             /** como no pubsub ao perder a conexão, a fila exclusiva é excluida, é necessário configurar
              * fila e etc novamente
@@ -125,7 +125,7 @@ 
                 true,
                 false,
                 false,
-                function (AMQPMessage $message) {
+                function(AMQPMessage $message) {
                     //se o status for negativo, não executa o consumo
                     $checkStatusCallback = $this->onCheckStatusCallback;
                     $statusBoolean = $checkStatusCallback();