WillRy / rabbitrun

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