.

rabbit_repo.py

@@ -17,11 +17,19 @@ class RabbitRepo(RabbitBase):
         self._source = external_source
 
     def _resolve_type(self, exch: str) -> str:
-        # Outbound: Use EXCHANGE_TYPES if present, else default to 'fanout'
-        matches = [k for k in settings.EXCHANGE_TYPES.keys() if exch.lower().startswith(k.lower())]
-        if matches:
-            return settings.EXCHANGE_TYPES[max(matches, key=len)]
-        return "fanout"  # Default for outbound
+        # First check for oa.* exchanges
+        if exch.lower().startswith("oa."):
+            return "direct"  # Default for oa.* exchanges
+    
+        # Then check EXCHANGE_TYPES if present
+        if hasattr(settings, 'EXCHANGE_TYPES') and settings.EXCHANGE_TYPES:
+            matches = [k for k in settings.EXCHANGE_TYPES.keys() 
+                      if exch.lower().startswith(k.lower())]
+            if matches:
+                return settings.EXCHANGE_TYPES[max(matches, key=len)]
+    
+        # Default fallback
+        return "fanout"
 
     async def publish(self, exchange: str, obj: Any, routing_key: str = "") -> None:
         ex = await self.ensure_exchange(exchange)