mgdigital / BusQue

src/Predis/PredisAdapter.php

Spacing +2 added lines, -2 removed lines

@@ -131,7 +131,7 @@ 
         $this->client->pipeline(function (ClientContextInterface $client) use ($queueName) {
             self::cDeleteQueue($client, $queueName);
         });
-        $this->clearSchedule([$queueName]);
+        $this->clearSchedule([ $queueName ]);
     }
 
     public function purgeCommand(string $queueName, string $id)
@@ -238,7 +238,7 @@ 
 
     private function storeCommandAndCheckIfIdReserved(string $queueName, string $id, string $serialized): bool
     {
-        list (, , $isReserved) = $this->client->pipeline(
+        list (,, $isReserved) = $this->client->pipeline(
             function (ClientContextInterface $client) use ($queueName, $id, $serialized) {
                 $client->hset(":{$queueName}:command_store", $id, $serialized);
                 self::cAddQueue($client, $queueName);