WillRy / rabbitrun

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/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 */

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

src/PubSub/PubSub.php

Spacing +3 added lines, -3 removed lines

@@ -82,7 +82,7 @@ 
     )
     {
 
-        $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
@@ -98,7 +98,7 @@ 
                 true,
                 false,
                 false,
-                function (AMQPMessage $message) {
+                function(AMQPMessage $message) {
                     $statusBoolean = $this->executeStatusCallback($message);
 
                     if (!$statusBoolean) {
@@ -149,7 +149,7 @@ 
         $this->exchange($this->exchangeName, 'fanout', false, false, false);
 
         $defaultQueueName = !empty($this->queueName) ? $this->queueName : '';
-        list($queueName, ,) = $this->queue($defaultQueueName, false, false, true, true);
+        list($queueName,,) = $this->queue($defaultQueueName, false, false, true, true);
 
         $this->queueName = $queueName;
 

src/Base.php

Spacing +2 added lines, -2 removed lines

@@ -33,10 +33,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);
         }

demo/pubsub/consumer.php

Spacing +4 added lines, -4 removed lines

@@ -22,7 +22,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() {
 });
 
 /**
@@ -31,7 +31,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";
 });
 
@@ -46,7 +46,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";
 });
 
@@ -54,7 +54,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/queue/consumer.php

Spacing +3 added lines, -3 removed lines

@@ -19,7 +19,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";
 });
 
@@ -34,7 +34,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";
 
@@ -52,7 +52,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";
 });