.

rabbit_base.py

@@ -40,9 +40,10 @@ class RabbitBase:
 
         # Disable SSL verification if using TLS
         if conn_kwargs.get("ssl"):
-            conn_kwargs["ssl_options"] = {
-                "cert_reqs": ssl.CERT_NONE
-            }
+            context = ssl.create_default_context()
+            context.check_hostname = False
+            context.verify_mode = ssl.CERT_NONE
+            conn_kwargs["ssl_options"] = context
 
         self._conn = await aio_pika.connect_robust(**conn_kwargs)
         self._chan = await self._conn.channel()