Merge pull request #4 from utopia-php/fix-remove-unnecessary-swoole-r…

…edis-connection

fix: remove unnecessary redis swoole connection

README.md

@@ -11,21 +11,23 @@ Although this library is part of the [Utopia Framework](https://github.com/utopi
 ## Getting Started
 
 Install using composer:
+
 ```bash
 composer require utopia-php/queue
 ```
 
 Init in your application:
+
 ```php
 <?php
 
 require_once __DIR__ . '/../../vendor/autoload.php';
 
-// Create a worker using swoole adapter
+// Create a worker using the Swoole adapter
 use Utopia\Queue;
 use Utopia\Queue\Message;
 
-$connection = new Queue\Connection\RedisSwoole('redis');
+$connection = new Queue\Connection\Redis('redis');
 $adapter = new Queue\Adapter\Swoole($connection, 12, 'swoole');
 $server = new Queue\Server($adapter);
 
@@ -49,19 +51,15 @@ $server
     ->start();
 
 
-// Enqueue messages to the worker using swoole adapter
-$connection = new RedisSwoole('redis', 6379);
-run(function () use ($connection) {
-    $client = new Client('swoole', $connection);
-    go(function () use ($client) {
-        $client->resetStats();
+// Enqueue messages to the worker using the Redis adapter
+$connection = new Redis('redis', 6379);
+$client = new Client('swoole', $connection);
+$client->resetStats();
 
-        $client->enqueue([
-            'type' => 'test_number',
-            'value' => 123
-        ]);
-    });
-});
+$client->enqueue([
+    'type' => 'test_number',
+    'value' => 123
+]);
 ```
 
 ## System Requirements

tests/Queue/e2e/AdapterTest.php

@@ -5,7 +5,6 @@
 use PHPUnit\Framework\TestCase;
 use Utopia\Queue\Client;
 use Utopia\Queue\Connection\Redis;
-use Utopia\Queue\Connection\RedisSwoole;
 
 use function Swoole\Coroutine\go;
 use function Swoole\Coroutine\run;
@@ -81,7 +80,7 @@ public function testEvents(): void
 
     public function testSwoole(): void
     {
-        $connection = new RedisSwoole('redis', 6379);
+        $connection = new Redis('redis', 6379);
 
         run(function () use ($connection) {
             $client = new Client('swoole', $connection);

tests/Queue/servers/Swoole/worker.php

@@ -6,7 +6,7 @@
 use Utopia\Queue;
 use Utopia\Queue\Message;
 
-$connection = new Queue\Connection\RedisSwoole('redis');
+$connection = new Queue\Connection\Redis('redis');
 $adapter = new Queue\Adapter\Swoole($connection, 12, 'swoole');
 $server = new Queue\Server($adapter);