equip / queue

src/Worker.php

Indentation +1 added lines, -1 removed lines

@@ -69,7 +69,7 @@
     {
         $packet = $this->driver->pop($queue);
         if (empty($packet)) {
-             return true;
+                return true;
         }
 
         $message = $this->serializer->deserialize($packet);

src/Event.php

Indentation +1 added lines, -1 removed lines

@@ -47,7 +47,7 @@
     public function finish(Message $message)
     {
         array_map(function ($name) use ($message) {
-           $this->emitter->emit($name, $message) ;
+            $this->emitter->emit($name, $message) ;
         }, [
             static::MESSAGE_FINISH,
             sprintf('%s.%s', static::MESSAGE_FINISH, $message->handler())

Spacing +4 added lines, -4 removed lines

@@ -31,7 +31,7 @@ 
      */
     public function acknowledge(Message $message)
     {
-        array_map(function ($name) use ($message) {
+        array_map(function($name) use ($message) {
             $this->emitter->emit($name, $message);
         }, [
             static::MESSAGE_ACKNOWLEDGE,
@@ -46,8 +46,8 @@ 
      */
     public function finish(Message $message)
     {
-        array_map(function ($name) use ($message) {
-           $this->emitter->emit($name, $message) ;
+        array_map(function($name) use ($message) {
+           $this->emitter->emit($name, $message);
         }, [
             static::MESSAGE_FINISH,
             sprintf('%s.%s', static::MESSAGE_FINISH, $message->handler())
@@ -62,7 +62,7 @@ 
      */
     public function reject(Message $message, Exception $exception)
     {
-        array_map(function ($name) use ($message, $exception) {
+        array_map(function($name) use ($message, $exception) {
             $this->emitter->emit($name, $message, $exception);
         }, [
             static::MESSAGE_REJECT,