From b3a1eb6d8c397fdd44bad0012e3999d25e22958d Mon Sep 17 00:00:00 2001
From: Inseok Lee <matt.lee@sendbird.com>
Date: Mon, 8 May 2023 12:42:08 +0900
Subject: [PATCH] Correctly close

---
 kombu/transport/redis_cluster.py | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/kombu/transport/redis_cluster.py b/kombu/transport/redis_cluster.py
index 8bc2f2373..0240643a0 100644
--- a/kombu/transport/redis_cluster.py
+++ b/kombu/transport/redis_cluster.py
@@ -202,6 +202,12 @@ def conn_or_acquire(self, client=None):
         else:
             yield self.client
 
+    def close(self):
+        for _, _, conn, _ in self.connection.cycle._chan_to_sock:
+            conn.client.close()
+
+        return super().close()
+
     def _create_client(self, asynchronous=False):
         conninfo = self.connection.client