enl / amqpworkers

src/Producer.php

Spacing +2 added lines, -2 removed lines

@@ -51,8 +51,8 @@
     {
         $this->connection = $connection;
 
-        $this->withFormatter(function ($message) {
-            return (string)$message;
+        $this->withFormatter(function($message) {
+            return (string) $message;
         });
     }
 

src/Consumer.php

Spacing +1 added lines, -1 removed lines

@@ -131,7 +131,7 @@
 
         $this->producer && $this->producer->selfCheck();
 
-        $wrapper = function (AMQPMessage $message) {
+        $wrapper = function(AMQPMessage $message) {
             $result = call_user_func($this->worker, $message->getBody());
 
             if ($result && $this->producer) {