mgdigital / BusQue

src/AutoQueue/AutoQueuingCommandBusAdapter.php

Spacing +4 added lines, -4 removed lines

@@ -8,7 +8,7 @@ 
 {
 
     private $baseCommandBus;
-    private $fromQueueCommands = [];
+    private $fromQueueCommands = [ ];
 
     public function __construct(CommandBusAdapterInterface $baseCommandBus)
     {
@@ -19,18 +19,18 @@ 
     {
         if ($fromQueue) {
             $hash = $this->getHash($command);
-            $this->fromQueueCommands[$hash] = true;
+            $this->fromQueueCommands[ $hash ] = true;
         }
         $this->baseCommandBus->handle($command, $fromQueue);
         if (isset($hash)) {
-            unset($this->fromQueueCommands[$hash]);
+            unset($this->fromQueueCommands[ $hash ]);
         }
     }
 
     public function shouldBeQueued($command): bool
     {
         $hash = $this->getHash($command);
-        return !isset($this->fromQueueCommands[$hash]);
+        return !isset($this->fromQueueCommands[ $hash ]);
     }
 
     private function getHash($command): string

src/AutoQueue/OrDecider.php

Spacing +2 added lines, -2 removed lines

@@ -8,12 +8,12 @@
     /**
      * @var DeciderInterface[]
      */
-    private $deciders = [];
+    private $deciders = [ ];
 
     public function __construct(array $deciders)
     {
         array_walk($deciders, function (DeciderInterface $decider) {
-            $this->deciders[] = $decider;
+            $this->deciders[ ] = $decider;
         });
     }
 

src/Tactician/ChainedInflector.php

Spacing +3 added lines, -3 removed lines

@@ -10,7 +10,7 @@ 
     /**
      * @var MethodNameInflector[]
      */
-    private $inflectors = [];
+    private $inflectors = [ ];
 
     /**
      * @param MethodNameInflector[] $inflectors
@@ -18,7 +18,7 @@ 
     public function __construct(array $inflectors)
     {
         array_walk($inflectors, function (MethodNameInflector $inflector) {
-            $this->inflectors[] = $inflector;
+            $this->inflectors[ ] = $inflector;
         });
     }
 
@@ -26,7 +26,7 @@ 
     {
         foreach ($this->inflectors as $inflector) {
             $methodName = $inflector->inflect($command, $handler);
-            if (is_callable([$handler, $methodName])) {
+            if (is_callable([ $handler, $methodName ])) {
                 return $methodName;
             }
         }

src/AutoQueue/AndDecider.php

Spacing +2 added lines, -2 removed lines

@@ -8,12 +8,12 @@
     /**
      * @var DeciderInterface[]
      */
-    private $deciders = [];
+    private $deciders = [ ];
 
     public function __construct(array $deciders)
     {
         array_walk($deciders, function (DeciderInterface $decider) {
-            $this->deciders[] = $decider;
+            $this->deciders[ ] = $decider;
         });
     }
 

src/Predis/PredisAdapter.php

Spacing +10 added lines, -10 removed lines

@@ -16,7 +16,7 @@ 
 class PredisAdapter implements QueueAdapterInterface, SchedulerAdapterInterface
 {
 
-    const LUA_PATH = __DIR__ . '/../../lua';
+    const LUA_PATH = __DIR__.'/../../lua';
 
     private $client;
 
@@ -27,7 +27,7 @@ 
 
     public function queueCommand(string $queueName, string $id, string $serialized)
     {
-        $this->executeLuaScript('queue_message', [$queueName, $id, $serialized]);
+        $this->executeLuaScript('queue_message', [ $queueName, $id, $serialized ]);
     }
 
     public function awaitCommand(string $queueName, int $timeout = null): ReceivedCommand
@@ -49,7 +49,7 @@ 
             return $this->awaitCommand($queueName, $timeout);
         }
         /* @var $id string */
-        $serialized = $this->executeLuaScript('receive_message', [$queueName, $id]);
+        $serialized = $this->executeLuaScript('receive_message', [ $queueName, $id ]);
         return new ReceivedCommand($queueName, $id, $serialized);
     }
 
@@ -60,12 +60,12 @@ 
 
     public function setCommandCompleted(string $queueName, string $id)
     {
-        $this->executeLuaScript('acknowledge_message', [$queueName, $id]);
+        $this->executeLuaScript('acknowledge_message', [ $queueName, $id ]);
     }
 
     public function setCommandFailed(string $queueName, string $id)
     {
-        $this->executeLuaScript('reject_message', [$queueName, $id]);
+        $this->executeLuaScript('reject_message', [ $queueName, $id ]);
     }
 
     public function putQueue(string $queueName)
@@ -109,23 +109,23 @@ 
 
     public function clearQueue(string $queueName)
     {
-        $this->executeLuaScript('empty_queue', [$queueName]);
+        $this->executeLuaScript('empty_queue', [ $queueName ]);
     }
 
     public function deleteQueue(string $queueName)
     {
         $this->clearQueue($queueName);
-        $this->clearSchedule([$queueName]);
+        $this->clearSchedule([ $queueName ]);
     }
 
     public function purgeCommand(string $queueName, string $id)
     {
-        $this->executeLuaScript('purge_message', [$queueName, $id]);
+        $this->executeLuaScript('purge_message', [ $queueName, $id ]);
     }
 
     public function scheduleCommand(string $queueName, string $id, string $serialized, \DateTime $dateTime)
     {
-        $this->executeLuaScript('schedule_message', [$queueName, $id, $serialized, $dateTime->getTimestamp()]);
+        $this->executeLuaScript('schedule_message', [ $queueName, $id, $serialized, $dateTime->getTimestamp() ]);
     }
 
     public function cancelScheduledCommand(string $queueName, string $id)
@@ -180,7 +180,7 @@ 
 
     private function executeLuaScript(string $script, array $args)
     {
-        $command = new LuaFileCommand(static::LUA_PATH . '/' . $script . '.lua');
+        $command = new LuaFileCommand(static::LUA_PATH.'/'.$script.'.lua');
         $command->setArguments($args);
         return $this->client->executeCommand($command);
     }

src/QueueResolver/ClassMapQueueResolver.php

Spacing +2 added lines, -2 removed lines

@@ -19,8 +19,8 @@
     {
         if (is_object($command)) {
             $class = get_class($command);
-            if (isset($this->map[$class])) {
-                return $this->map[$class];
+            if (isset($this->map[ $class ])) {
+                return $this->map[ $class ];
             }
         }
         throw new QueueResolverException;