mgdigital / BusQue

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