diff --git a/.github/workflows/tests.yml b/.github/workflows/tests.yml
index 6391332..ed5bb80 100644
--- a/.github/workflows/tests.yml
+++ b/.github/workflows/tests.yml
@@ -16,6 +16,7 @@ jobs:
         adapter:
           [
             AMQP,
+            Pool,
             SwooleRedisCluster,
             Swoole,
             Workerman,
diff --git a/Dockerfile b/Dockerfile
index 94354a4..565cb52 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -1,4 +1,4 @@
-FROM composer as composer
+FROM composer AS composer
 
 WORKDIR /usr/local/src/
 
diff --git a/composer.json b/composer.json
index 6252380..7de9530 100644
--- a/composer.json
+++ b/composer.json
@@ -29,6 +29,7 @@
         "utopia-php/cli": "0.15.*",
         "utopia-php/framework": "0.33.*",
         "utopia-php/telemetry": "0.1.*",
+        "utopia-php/pools": "0.8.*",
         "utopia-php/fetch": "0.4.*"
     },
     "require-dev": {
diff --git a/composer.lock b/composer.lock
index 0b9eb3c..126551c 100644
--- a/composer.lock
+++ b/composer.lock
@@ -4,7 +4,7 @@
         "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
         "This file is @generated automatically"
     ],
-    "content-hash": "77db808700b06a060b72e56ba5d9ac91",
+    "content-hash": "574ad3b103f97c1668af99674784aae8",
     "packages": [
         {
             "name": "brick/math",
@@ -593,16 +593,16 @@
         },
         {
             "name": "open-telemetry/sdk",
-            "version": "1.2.2",
+            "version": "1.2.4",
             "source": {
                 "type": "git",
                 "url": "https://github.com/opentelemetry-php/sdk.git",
-                "reference": "37eec0fe47ddd627911f318f29b6cd48196be0c0"
+                "reference": "47fcb66ae5328c5a799195247b1dce551d85873e"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/opentelemetry-php/sdk/zipball/37eec0fe47ddd627911f318f29b6cd48196be0c0",
-                "reference": "37eec0fe47ddd627911f318f29b6cd48196be0c0",
+                "url": "https://api.github.com/repos/opentelemetry-php/sdk/zipball/47fcb66ae5328c5a799195247b1dce551d85873e",
+                "reference": "47fcb66ae5328c5a799195247b1dce551d85873e",
                 "shasum": ""
             },
             "require": {
@@ -679,7 +679,7 @@
                 "issues": "https://github.com/open-telemetry/opentelemetry-php/issues",
                 "source": "https://github.com/open-telemetry/opentelemetry-php"
             },
-            "time": "2025-01-29T21:40:28+00:00"
+            "time": "2025-04-15T07:02:07+00:00"
         },
         {
             "name": "open-telemetry/sem-conv",
@@ -2037,16 +2037,16 @@
         },
         {
             "name": "tbachert/spi",
-            "version": "v1.0.2",
+            "version": "v1.0.3",
             "source": {
                 "type": "git",
                 "url": "https://github.com/Nevay/spi.git",
-                "reference": "2ddfaf815dafb45791a61b08170de8d583c16062"
+                "reference": "506a79c98e1a51522e76ee921ccb6c62d52faf3a"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/Nevay/spi/zipball/2ddfaf815dafb45791a61b08170de8d583c16062",
-                "reference": "2ddfaf815dafb45791a61b08170de8d583c16062",
+                "url": "https://api.github.com/repos/Nevay/spi/zipball/506a79c98e1a51522e76ee921ccb6c62d52faf3a",
+                "reference": "506a79c98e1a51522e76ee921ccb6c62d52faf3a",
                 "shasum": ""
             },
             "require": {
@@ -2083,22 +2083,22 @@
             ],
             "support": {
                 "issues": "https://github.com/Nevay/spi/issues",
-                "source": "https://github.com/Nevay/spi/tree/v1.0.2"
+                "source": "https://github.com/Nevay/spi/tree/v1.0.3"
             },
-            "time": "2024-10-04T16:36:12+00:00"
+            "time": "2025-04-02T19:38:14+00:00"
         },
         {
             "name": "utopia-php/cli",
-            "version": "0.15.1",
+            "version": "0.15.2",
             "source": {
                 "type": "git",
                 "url": "https://github.com/utopia-php/cli.git",
-                "reference": "d69bbe51a6a94dc4e5bcdd542b5938038b985a65"
+                "reference": "da00ff6b8b29a826a1794002ae43442cdf3a0f5f"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/utopia-php/cli/zipball/d69bbe51a6a94dc4e5bcdd542b5938038b985a65",
-                "reference": "d69bbe51a6a94dc4e5bcdd542b5938038b985a65",
+                "url": "https://api.github.com/repos/utopia-php/cli/zipball/da00ff6b8b29a826a1794002ae43442cdf3a0f5f",
+                "reference": "da00ff6b8b29a826a1794002ae43442cdf3a0f5f",
                 "shasum": ""
             },
             "require": {
@@ -2132,9 +2132,9 @@
             ],
             "support": {
                 "issues": "https://github.com/utopia-php/cli/issues",
-                "source": "https://github.com/utopia-php/cli/tree/0.15.1"
+                "source": "https://github.com/utopia-php/cli/tree/0.15.2"
             },
-            "time": "2024-10-04T13:55:36+00:00"
+            "time": "2025-04-15T10:08:48+00:00"
         },
         {
             "name": "utopia-php/compression",
@@ -2184,16 +2184,16 @@
         },
         {
             "name": "utopia-php/fetch",
-            "version": "0.4.0",
+            "version": "0.4.1",
             "source": {
                 "type": "git",
                 "url": "https://github.com/utopia-php/fetch.git",
-                "reference": "46e791ff6a95864517750b9df6bbf4a17e3c9c4e"
+                "reference": "65095dac14037db0c822fb5e209e5bd3187a0303"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/utopia-php/fetch/zipball/46e791ff6a95864517750b9df6bbf4a17e3c9c4e",
-                "reference": "46e791ff6a95864517750b9df6bbf4a17e3c9c4e",
+                "url": "https://api.github.com/repos/utopia-php/fetch/zipball/65095dac14037db0c822fb5e209e5bd3187a0303",
+                "reference": "65095dac14037db0c822fb5e209e5bd3187a0303",
                 "shasum": ""
             },
             "require": {
@@ -2217,9 +2217,9 @@
             "description": "A simple library that provides an interface for making HTTP Requests.",
             "support": {
                 "issues": "https://github.com/utopia-php/fetch/issues",
-                "source": "https://github.com/utopia-php/fetch/tree/0.4.0"
+                "source": "https://github.com/utopia-php/fetch/tree/0.4.1"
             },
-            "time": "2025-03-11T21:06:56+00:00"
+            "time": "2025-04-14T07:34:27+00:00"
         },
         {
             "name": "utopia-php/framework",
@@ -2268,6 +2268,58 @@
             },
             "time": "2025-03-06T11:37:49+00:00"
         },
+        {
+            "name": "utopia-php/pools",
+            "version": "0.8.2",
+            "source": {
+                "type": "git",
+                "url": "https://github.com/utopia-php/pools.git",
+                "reference": "05c67aba42eb68ac65489cc1e7fc5db83db2dd4d"
+            },
+            "dist": {
+                "type": "zip",
+                "url": "https://api.github.com/repos/utopia-php/pools/zipball/05c67aba42eb68ac65489cc1e7fc5db83db2dd4d",
+                "reference": "05c67aba42eb68ac65489cc1e7fc5db83db2dd4d",
+                "shasum": ""
+            },
+            "require": {
+                "php": ">=8.3",
+                "utopia-php/telemetry": "0.1.*"
+            },
+            "require-dev": {
+                "laravel/pint": "1.*",
+                "phpstan/phpstan": "1.*",
+                "phpunit/phpunit": "11.*"
+            },
+            "type": "library",
+            "autoload": {
+                "psr-4": {
+                    "Utopia\\Pools\\": "src/Pools"
+                }
+            },
+            "notification-url": "https://packagist.org/downloads/",
+            "license": [
+                "MIT"
+            ],
+            "authors": [
+                {
+                    "name": "Team Appwrite",
+                    "email": "team@appwrite.io"
+                }
+            ],
+            "description": "A simple library to manage connection pools",
+            "keywords": [
+                "framework",
+                "php",
+                "pools",
+                "utopia"
+            ],
+            "support": {
+                "issues": "https://github.com/utopia-php/pools/issues",
+                "source": "https://github.com/utopia-php/pools/tree/0.8.2"
+            },
+            "time": "2025-04-17T02:04:54+00:00"
+        },
         {
             "name": "utopia-php/telemetry",
             "version": "0.1.1",
@@ -2694,16 +2746,16 @@
         },
         {
             "name": "phpstan/phpstan",
-            "version": "1.12.23",
+            "version": "1.12.24",
             "source": {
                 "type": "git",
                 "url": "https://github.com/phpstan/phpstan.git",
-                "reference": "29201e7a743a6ab36f91394eab51889a82631428"
+                "reference": "338b92068f58d9f8035b76aed6cf2b9e5624c025"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/phpstan/phpstan/zipball/29201e7a743a6ab36f91394eab51889a82631428",
-                "reference": "29201e7a743a6ab36f91394eab51889a82631428",
+                "url": "https://api.github.com/repos/phpstan/phpstan/zipball/338b92068f58d9f8035b76aed6cf2b9e5624c025",
+                "reference": "338b92068f58d9f8035b76aed6cf2b9e5624c025",
                 "shasum": ""
             },
             "require": {
@@ -2748,7 +2800,7 @@
                     "type": "github"
                 }
             ],
-            "time": "2025-03-23T14:57:32+00:00"
+            "time": "2025-04-16T13:01:53+00:00"
         },
         {
             "name": "phpunit/php-code-coverage",
diff --git a/src/Queue/Broker/Pool.php b/src/Queue/Broker/Pool.php
new file mode 100644
index 0000000..8fcf5f0
--- /dev/null
+++ b/src/Queue/Broker/Pool.php
@@ -0,0 +1,56 @@
+<?php
+
+namespace Utopia\Queue\Broker;
+
+use Utopia\Queue\Consumer;
+use Utopia\Queue\Publisher;
+use Utopia\Queue\Queue;
+use Utopia\Pools\Pool as UtopiaPool;
+
+readonly class Pool implements Publisher, Consumer
+{
+    public function __construct(
+        private ?UtopiaPool $publisher = null,
+        private ?UtopiaPool $consumer = null,
+    ) {
+    }
+
+    public function enqueue(Queue $queue, array $payload): bool
+    {
+        return $this->delegatePublish(__FUNCTION__, \func_get_args());
+    }
+
+    public function retry(Queue $queue, ?int $limit = null): void
+    {
+        $this->delegatePublish(__FUNCTION__, \func_get_args());
+    }
+
+    public function getQueueSize(Queue $queue, bool $failedJobs = false): int
+    {
+        return $this->delegatePublish(__FUNCTION__, \func_get_args());
+    }
+
+    public function consume(Queue $queue, callable $messageCallback, callable $successCallback, callable $errorCallback): void
+    {
+        $this->delegateConsumer(__FUNCTION__, \func_get_args());
+    }
+
+    public function close(): void
+    {
+        $this->delegateConsumer(__FUNCTION__, \func_get_args());
+    }
+
+    protected function delegatePublish(string $method, array $args): mixed
+    {
+        return $this->publisher?->use(function (Publisher $adapter) use ($method, $args) {
+            return $adapter->$method(...$args);
+        });
+    }
+
+    protected function delegateConsumer(string $method, array $args): mixed
+    {
+        return $this->consumer?->use(function (Consumer $adapter) use ($method, $args) {
+            return $adapter->$method(...$args);
+        });
+    }
+}
diff --git a/tests/Queue/E2E/Adapter/AMQPTest.php b/tests/Queue/E2E/Adapter/AMQPTest.php
index dac71bd..e8557a3 100644
--- a/tests/Queue/E2E/Adapter/AMQPTest.php
+++ b/tests/Queue/E2E/Adapter/AMQPTest.php
@@ -1,8 +1,7 @@
 <?php
 
-namespace Queue\E2E\Adapter;
+namespace Tests\E2E\Adapter;
 
-use Tests\E2E\Adapter\Base;
 use Utopia\Queue\Broker\AMQP;
 use Utopia\Queue\Publisher;
 use Utopia\Queue\Queue;
diff --git a/tests/Queue/E2E/Adapter/PoolTest.php b/tests/Queue/E2E/Adapter/PoolTest.php
new file mode 100644
index 0000000..8c02d2b
--- /dev/null
+++ b/tests/Queue/E2E/Adapter/PoolTest.php
@@ -0,0 +1,27 @@
+<?php
+
+namespace Tests\E2E\Adapter;
+
+use Utopia\Pools\Pool as UtopiaPool;
+use Utopia\Queue\Broker\Pool;
+use Utopia\Queue\Broker\Redis as RedisBroker;
+use Utopia\Queue\Connection\Redis;
+use Utopia\Queue\Publisher;
+use Utopia\Queue\Queue;
+
+class PoolTest extends Base
+{
+    protected function getPublisher(): Publisher
+    {
+        $pool = new UtopiaPool('redis', 1, function () {
+            return new RedisBroker(new Redis('redis', 6379));
+        });
+
+        return new Pool($pool, $pool);
+    }
+
+    protected function getQueue(): Queue
+    {
+        return new Queue('pool');
+    }
+}
diff --git a/tests/Queue/E2E/Adapter/SwooleRedisClusterTest.php b/tests/Queue/E2E/Adapter/SwooleRedisClusterTest.php
index 2e02744..b1a744c 100644
--- a/tests/Queue/E2E/Adapter/SwooleRedisClusterTest.php
+++ b/tests/Queue/E2E/Adapter/SwooleRedisClusterTest.php
@@ -1,8 +1,7 @@
 <?php
 
-namespace Queue\E2E\Adapter;
+namespace Tests\E2E\Adapter;
 
-use Tests\E2E\Adapter\Base;
 use Utopia\Queue\Broker\Redis;
 use Utopia\Queue\Connection\RedisCluster;
 use Utopia\Queue\Publisher;