WillRy / rabbitrun

src/PubSub/PubSub.php

Spacing +2 added lines, -2 removed lines

@@ -110,7 +110,7 @@ 
     ) {
         if ($sleepSeconds < 1) $sleepSeconds = 1;
 
-        $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
@@ -126,7 +126,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();

src/Queue/Queue.php

Spacing +2 added lines, -2 removed lines

@@ -119,7 +119,7 @@ 
             throw new \Exception("Define a onExecuting callback");
         }
 
-        $this->loopConnection(function () use ($sleepSeconds, $queueName) {
+        $this->loopConnection(function() use ($sleepSeconds, $queueName) {
 
             $this->createQueue($queueName);
 
@@ -132,7 +132,7 @@ 
                 false,
                 false,
                 false,
-                function (AMQPMessage $message) {
+                function(AMQPMessage $message) {
                     //se o status for negativo, não executa o consumo
                     if (!empty($this->onCheckStatusCallback)) {
                         $checkStatusCallback = $this->onCheckStatusCallback;

src/Base.php

Spacing +4 added lines, -4 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;
         }
     }

demo/queue_db/PdoDriver.php

Spacing +1 added lines, -1 removed lines

@@ -43,7 +43,7 @@
         $stmt->execute();
         $task = $stmt->fetch(\PDO::FETCH_ASSOC);
 
-        if(empty($task)) {
+        if (empty($task)) {
             return false;
         }
 

demo/queue_db/consumer.php

Spacing +4 added lines, -4 removed lines

@@ -23,12 +23,12 @@ 
 $model = new PdoMonitor("rabbit_monitor", $consumerName, 'servicos');
 $model->insertConsumerIfNotExists();
 
-$worker->onCheckStatus(function () use ($consumerName) {
+$worker->onCheckStatus(function() use ($consumerName) {
     $model = new PdoMonitor("rabbit_monitor", $consumerName, 'servicos');
     return $model->workerIsRunning();
 });
 
-$worker->onReceive(function ($dados) {
+$worker->onReceive(function($dados) {
     $id = $dados['payload']['id'];
     echo ' [x] [  receive  ] ', $id, "\n";
 
@@ -51,7 +51,7 @@ 
 
     return true;
 });
-$worker->onExecuting(function (AMQPMessage $message, $dados) {
+$worker->onExecuting(function(AMQPMessage $message, $dados) {
     $payload = $dados['payload'];
 
     echo ' [x] [  executing  ] ', $payload['id'], "\n";
@@ -63,7 +63,7 @@ 
 
     echo ' [x] [  success  ] ', $payload['id'], "\n";
 });
-$worker->onError(function (\Exception $e, $dados) {
+$worker->onError(function(\Exception $e, $dados) {
     $payload = $dados['payload'];
     $id = $payload['id'];
 

demo/pubsub/consumer.php

Spacing +4 added lines, -4 removed lines

@@ -23,7 +23,7 @@ 
  * Utilidade: Dizer se o worker está ativo, com base em algum registro de banco de dados, monitor de serviços
  * e etc
  */
-$worker->onCheckStatus(function () {
+$worker->onCheckStatus(function() {
 
 });
 
@@ -33,7 +33,7 @@ 
  *
  * Se não retornar nada ou verdadeiro, o item é processado no método onExecuting
  */
-$worker->onReceive(function ($dados) {
+$worker->onReceive(function($dados) {
     echo ' [x] [  receive  ] ', json_encode($dados), "\n";
 });
 
@@ -48,7 +48,7 @@ 
  * Se alguma exception não for tratada, o item será recolocado
  * na fila
  */
-$worker->onExecuting(function (AMQPMessage $message, $dados) {
+$worker->onExecuting(function(AMQPMessage $message, $dados) {
     echo ' [x] [ executing ] ', json_encode($dados), "\n";
 });
 
@@ -56,7 +56,7 @@ 
  * Método que executa automaticamente caso aconteça uma exception não tratada
  * durante o processamento
  */
-$worker->onError(function (\Exception $e, $dados) {
+$worker->onError(function(\Exception $e, $dados) {
     echo ' [x] [   error   ] ', json_encode($dados), "\n";
 });
 

demo/pubsub/Process.php

Spacing +1 added lines, -1 removed lines

@@ -17,7 +17,7 @@
         // $fakeException = rand() % 2 === 0;
         // if ($fakeException) throw new \Exception("=== Erro ===");
 
-        echo "Processado".PHP_EOL;
+        echo "Processado" . PHP_EOL;
 
 
         /** Marca o item como erro */

demo/queue/consumer.php

Spacing +4 added lines, -4 removed lines

@@ -23,7 +23,7 @@ 
  * Utilidade: Dizer se o worker está ativo, com base em algum registro de banco de dados, monitor de serviços
  * e etc
  */
-$worker->onCheckStatus(function () {
+$worker->onCheckStatus(function() {
 
 });
 
@@ -33,7 +33,7 @@ 
  *
  * Se não retornar nada ou verdadeiro, o item é processado no método onExecuting
  */
-$worker->onReceive(function ($dados) {
+$worker->onReceive(function($dados) {
     echo ' [x] [  receive  ] ', json_encode($dados), "\n";
 });
 
@@ -48,7 +48,7 @@ 
  * Se alguma exception não for tratada, o item será recolocado
  * na fila
  */
-$worker->onExecuting(function (AMQPMessage $message, $dados) {
+$worker->onExecuting(function(AMQPMessage $message, $dados) {
 
     echo ' [x] [ executing ] ', json_encode($dados), "\n";
 
@@ -62,7 +62,7 @@ 
  * Método que executa automaticamente caso aconteça uma exception não tratada
  * durante o processamento
  */
-$worker->onError(function (\Exception $e, $dados) {
+$worker->onError(function(\Exception $e, $dados) {
     echo ' [x] [   error   ] ', json_encode($dados), "\n";
 });