daikon-cqrs / rabbitmq3-adapter

src/Migration/RabbitMq3MigrationAdapter.php

Spacing +2 added lines, -2 removed lines

@@ -21,8 +21,8 @@
 
     public function read(string $identifier): MigrationList
     {
-        $currentMigrations= $this->loadMigrations();
-        $migrations = array_filter($currentMigrations, function ($migration) use ($identifier) {
+        $currentMigrations = $this->loadMigrations();
+        $migrations = array_filter($currentMigrations, function($migration) use ($identifier) {
             return $migration['routing_key'] === $identifier;
         });
 

src/Worker/RabbitMq3Worker.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
         $queue = $this->settings['queue'];
         Assertion::notBlank($queue);
 
-        $messageHandler = function (AMQPMessage $message) {
+        $messageHandler = function(AMQPMessage $message) {
             $this->execute($message);
         };