WillRy / rabbitrun

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