enl / amqpworkers

src/Consumer.php

Spacing +1 added lines, -1 removed lines

@@ -120,7 +120,7 @@
             throw new ConsumerNotProperlyConfigured('Worker is not defined.');
         }
 
-        $wrapper = function (AMQPMessage $message) {
+        $wrapper = function(AMQPMessage $message) {
             $result = call_user_func($this->worker, $message->getBody());
 
             if ($result && $this->producer) {

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