mgdigital / BusQue

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/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;

src/Serializer/PHPCommandSerializer.php

Spacing +1 added lines, -1 removed lines

@@ -15,7 +15,7 @@
 
     public function unserialize(string $serialized)
     {
-        set_error_handler([$this, 'handleError']);
+        set_error_handler([ $this, 'handleError' ]);
         $unserialized = unserialize($serialized);
         restore_error_handler();
         return $unserialized;

src/Redis/Predis/Client.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
     public function getIterator()
     {
         if (!$this->getConnection() instanceof \Traversable) {
-            return new \ArrayIterator([$this]);
+            return new \ArrayIterator([ $this ]);
         }
         return parent::getIterator();
     }

src/Redis/RedisDriver.php

Spacing +9 added lines, -9 removed lines

@@ -14,7 +14,7 @@ 
 final class RedisDriver implements QueueDriverInterface, SchedulerDriverInterface
 {
 
-    const LUA_PATH = __DIR__ . '/../../lua';
+    const LUA_PATH = __DIR__.'/../../lua';
 
     private $adapter;
     private $namespace;
@@ -30,7 +30,7 @@ 
 
     public function queueCommand(string $queueName, string $commandId, string $serialized)
     {
-        $this->evalScript('queue_message', [$this->namespace, $queueName, $commandId, $serialized]);
+        $this->evalScript('queue_message', [ $this->namespace, $queueName, $commandId, $serialized ]);
     }
 
     public function awaitCommand(string $queueName, int $timeout = null): ReceivedCommand
@@ -47,7 +47,7 @@ 
             $id = null;
         }
         if (!empty($id)) {
-            $serialized = $this->evalScript('receive_message', [$this->namespace, $queueName, $id]);
+            $serialized = $this->evalScript('receive_message', [ $this->namespace, $queueName, $id ]);
             if (!empty($serialized)) {
                 return new ReceivedCommand($queueName, $id, $serialized);
             }
@@ -63,7 +63,7 @@ 
 
     public function completeCommand(string $queueName, string $id)
     {
-        $this->evalScript('acknowledge_message', [$this->namespace, $queueName, $id]);
+        $this->evalScript('acknowledge_message', [ $this->namespace, $queueName, $id ]);
     }
 
     public function putQueue(string $queueName)
@@ -122,19 +122,19 @@ 
 
     public function deleteQueue(string $queueName)
     {
-        $this->evalScript('empty_queue', [$this->namespace, $queueName]);
+        $this->evalScript('empty_queue', [ $this->namespace, $queueName ]);
     }
 
     public function purgeCommand(string $queueName, string $id)
     {
-        $this->evalScript('purge_message', [$this->namespace, $queueName, $id]);
+        $this->evalScript('purge_message', [ $this->namespace, $queueName, $id ]);
     }
 
     public function scheduleCommand(string $queueName, string $id, string $serialized, \DateTime $dateTime)
     {
         $this->evalScript(
             'schedule_message',
-            [$this->namespace, $queueName, $id, $serialized, $dateTime->getTimestamp()]
+            [ $this->namespace, $queueName, $id, $serialized, $dateTime->getTimestamp() ]
         );
     }
 
@@ -202,7 +202,7 @@ 
 
     public function purgeNamespace()
     {
-        $this->evalScript('purge_namespace', [$this->namespace]);
+        $this->evalScript('purge_namespace', [ $this->namespace ]);
     }
 
     private function evalScript(string $script, array $args)
@@ -212,6 +212,6 @@ 
 
     private function getScriptPath(string $script): string
     {
-        return self::LUA_PATH . '/' . $script . '.lua';
+        return self::LUA_PATH.'/'.$script.'.lua';
     }
 }