mgdigital / BusQue

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