symfony
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/CHANGELOG.md
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/CHANGELOG.md
+5Lines changed: 5 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/CHANGELOG.md
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/CHANGELOG.md
+5Lines changed: 5 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/ConnectionTest.php
+17Lines changed: 17 additions & 0 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/ConnectionTest.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Tests/Transport/ConnectionTest.php
+17Lines changed: 17 additions & 0 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
+10-4Lines changed: 10 additions & 4 deletions b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/Connection.php
+10-4Lines changed: 10 additions & 4 deletions
diff --git a/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisProxy.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisProxy.php
+4-1Lines changed: 4 additions & 1 deletion b/‎src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisProxy.php
Copy file name to clipboardExpand all lines: src/Symfony/Component/Messenger/Bridge/Redis/Transport/RedisProxy.php
+4-1Lines changed: 4 additions & 1 deletion
@@ -1,6 +1,11 @@
 CHANGELOG
 =========
 
+5.3.0
+-----
+
+ * Added support for `\RedisCluster` instance in `Connection` constructor
+
 5.2.0
 -----
 
 
@@ -40,6 +40,15 @@ public static function setUpBeforeClass(): void
         }
     }
 
+    private function skipIfRedisClusterUnavailable()
+    {
+        try {
+            new \RedisCluster(null, explode(' ', getenv('REDIS_CLUSTER_HOSTS')));
+        } catch (\Exception $e) {
+            self::markTestSkipped($e->getMessage());
+        }
+    }
+
     public function testFromInvalidDsn()
     {
         $this->expectException(\InvalidArgumentException::class);
@@ -143,6 +152,14 @@ public function testDeprecationIfInvalidOptionIsPassedWithDsn()
         Connection::fromDsn('redis://localhost/queue?foo=bar');
     }
 
+    public function testRedisClusterInstanceIsSupported()
+    {
+        $this->skipIfRedisClusterUnavailable();
+
+        $redis = new \RedisCluster(null, explode(' ', getenv('REDIS_CLUSTER_HOSTS')));
+        $this->assertInstanceOf(Connection::class, new Connection([], [], [], $redis));
+    }
+
     public function testKeepGettingPendingMessages()
     {
         $redis = $this->createMock(\Redis::class);
 
@@ -56,7 +56,10 @@ class Connection
     private $deleteAfterReject;
     private $couldHavePendingMessages = true;
 
-    public function __construct(array $configuration, array $connectionCredentials = [], array $redisOptions = [], \Redis $redis = null)
+    /**
+     * @param \Redis|\RedisCluster|null $redis
+     */
+    public function __construct(array $configuration, array $connectionCredentials = [], array $redisOptions = [], $redis = null)
     {
         if (version_compare(phpversion('redis'), '4.3.0', '<')) {
             throw new LogicException('The redis transport requires php-redis 4.3.0 or higher.');
@@ -72,14 +75,17 @@ public function __construct(array $configuration, array $connectionCredentials =
         }
 
         $initializer = static function ($redis) use ($host, $port, $auth, $serializer, $dbIndex) {
-            $redis->connect($host, $port);
+            if ($redis instanceof \Redis) {
+                $redis->connect($host, $port);
+            }
+
             $redis->setOption(\Redis::OPT_SERIALIZER, $serializer);
 
-            if (null !== $auth && !$redis->auth($auth)) {
+            if (null !== $auth && $redis instanceof \Redis && !$redis->auth($auth)) {
                 throw new InvalidArgumentException('Redis connection failed: '.$redis->getLastError());
             }
 
-            if ($dbIndex && !$redis->select($dbIndex)) {
+            if ($dbIndex && $redis instanceof \Redis && !$redis->select($dbIndex)) {
                 throw new InvalidArgumentException('Redis connection failed: '.$redis->getLastError());
             }
 
 
@@ -25,7 +25,10 @@ class RedisProxy
     private $initializer;
     private $ready = false;
 
-    public function __construct(\Redis $redis, \Closure $initializer)
+    /**
+     * @param \Redis|\RedisCluster $redis
+     */
+    public function __construct($redis, \Closure $initializer)
     {
         $this->redis = $redis;
         $this->initializer = $initializer;