Feat: Implement ping method

README.md

@@ -28,6 +28,13 @@ use Utopia\Queue;
 use Utopia\Queue\Message;
 
 $connection = new Queue\Connection\Redis('redis');
+
+if ($connection->ping()) {
+    var_dump('Connection is ready.');
+} else {
+    var_dump('Connection is not ready.');
+}
+
 $adapter = new Queue\Adapter\Swoole($connection, 12, 'my-queue');
 $server = new Queue\Server($adapter);
 

src/Queue/Connection.php

@@ -24,4 +24,5 @@ public function get(string $key): array|string|null;
     public function setArray(string $key, array $value): bool;
     public function increment(string $key): int;
     public function decrement(string $key): int;
+    public function ping(): bool;
 }

src/Queue/Connection/Redis.php

@@ -159,6 +159,17 @@ public function listRange(string $key, int $total, int $offset): array
         return array_map(fn (array $job) => new Message($job), $results);
     }
 
+    public function ping(): bool
+    {
+        try {
+            $this->getRedis()->ping();
+
+            return true;
+        } catch (\Exception $e) {
+            return false;
+        }
+    }
+
     protected function getRedis(): \Redis
     {
         if ($this->redis) {

tests/Queue/e2e/AdapterTest.php

@@ -62,9 +62,12 @@ public function testEvents(): void
     {
         $connection = new Redis('redis', 6379);
 
+        $this->assertTrue($connection->ping());
+
         $client = new Client('workerman', $connection);
         $client->resetStats();
 
+
         foreach ($this->payloads as $payload) {
             $this->assertTrue($client->enqueue($payload));
         }