.

rabbit_base.py

@@ -1,8 +1,8 @@
-# rabbit_base.py
 from typing import Callable, Dict, List, Optional
 import aio_pika
 from urllib.parse import urlsplit, unquote
 from config import settings
+import ssl  # ✅ correct import
 
 ExchangeResolver = Callable[[str], str]  # exchangeName -> exchangeType
 
@@ -35,7 +35,15 @@ class RabbitBase:
     async def connect(self) -> None:
         if self._conn and not self._conn.is_closed:
             return
+
         conn_kwargs = _parse_amqp_url(str(settings.AMQP_URL))
+
+        # Disable SSL verification if using TLS
+        if conn_kwargs.get("ssl"):
+            conn_kwargs["ssl_options"] = {
+                "cert_reqs": ssl.CERT_NONE
+            }
+
         self._conn = await aio_pika.connect_robust(**conn_kwargs)
         self._chan = await self._conn.channel()
         await self._chan.set_qos(prefetch_count=settings.RABBIT_PREFETCH)