.

rabbit_base.py

@@ -2,7 +2,7 @@ from typing import Callable, Dict, List, Optional
 import aio_pika
 from urllib.parse import urlsplit, unquote
 from config import settings
-import ssl  # ✅ correct import
+import ssl
 
 ExchangeResolver = Callable[[str], str]  # exchangeName -> exchangeType
 
@@ -19,7 +19,7 @@ def _parse_amqp_url(url: str) -> dict:
         "login": parts.username or "guest",
         "password": parts.password or "guest",
         "virtualhost": unquote(parts.path[1:] or "/"),
-        "ssl": parts.scheme == "amqps",
+        "ssl": parts.scheme == "amqps",  # bool for now; we may override with SSLContext
     }
 
 
@@ -38,12 +38,12 @@ class RabbitBase:
 
         conn_kwargs = _parse_amqp_url(str(settings.AMQP_URL))
 
-        # Disable SSL verification if using TLS
+        # Proper way: override the boolean with an SSLContext to disable verification
         if conn_kwargs.get("ssl"):
-            context = ssl.create_default_context()
-            context.check_hostname = False
-            context.verify_mode = ssl.CERT_NONE
-            conn_kwargs["ssl_options"] = {"context": context}
+            ctx = ssl.create_default_context()
+            ctx.check_hostname = False
+            ctx.verify_mode = ssl.CERT_NONE
+            conn_kwargs["ssl"] = ctx  # <-- pass the context here, not via ssl_options
 
         self._conn = await aio_pika.connect_robust(**conn_kwargs)
         self._chan = await self._conn.channel()