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/RedisDriver.php

Spacing +8 added lines, -8 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 $time = null): ReceivedCommand
@@ -43,7 +43,7 @@ 
         if (empty($id)) {
             throw new TimeoutException;
         }
-        $serialized = $this->evalScript('receive_message', [$this->namespace, $queueName, $id]);
+        $serialized = $this->evalScript('receive_message', [ $this->namespace, $queueName, $id ]);
         if (empty($serialized)) {
             throw new DriverException(sprintf('Error retrieving command %s.', $id));
         }
@@ -101,19 +101,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() ]
         );
     }
 
@@ -181,12 +181,12 @@ 
 
     public function purgeNamespace()
     {
-        $this->evalScript('purge_namespace', [$this->namespace]);
+        $this->evalScript('purge_namespace', [ $this->namespace ]);
     }
 
     private function evalScript(string $script, array $args)
     {
-        $path = self::LUA_PATH . '/' . $script . '.lua';
+        $path = self::LUA_PATH.'/'.$script.'.lua';
         $lua = file_get_contents($path);
         return $this->adapter->evalLua($lua, $args);
     }

src/SchedulerWorker.php

Spacing +1 added lines, -1 removed lines

@@ -51,7 +51,7 @@
         if ($expiry === null) {
             $start = null;
         } else {
-            $start = new \DateTimeImmutable('@' . ($now->getTimestamp() - $expiry->s));
+            $start = new \DateTimeImmutable('@'.($now->getTimestamp() - $expiry->s));
         }
         $receivedCommands = $this->implementation->getSchedulerDriver()
             ->receiveDueCommands($now, $throttle, $start);