.

rabbit_base.py

@@ -43,7 +43,7 @@ class RabbitBase:
             context = ssl.create_default_context()
             context.check_hostname = False
             context.verify_mode = ssl.CERT_NONE
-            conn_kwargs["ssl_options"] = context
+            conn_kwargs["ssl_options"] = {"context": context}
 
         self._conn = await aio_pika.connect_robust(**conn_kwargs)
         self._chan = await self._conn.channel()