.

config.py

@@ -11,8 +11,17 @@ APPSETTINGS_PATH = os.environ.get("APPSETTINGS_JSON", "appsettings.json")
 class Settings:
     """Settings object with attribute access."""
     def __init__(self, data: dict):
-        for k, v in data.items():
-            setattr(self, k, v)
+        self._data = data
+
+    @property
+    def EXCHANGE_TYPES(self):
+        # Prefer nested config, fallback to root
+        rabbitmq = self._data.get("RabbitMQ", {})
+        return rabbitmq.get("ExchangeTypes", self._data.get("EXCHANGE_TYPES", {}))
+
+    @property
+    def RABBIT_EXCHANGE_TYPE(self):
+        return self._data.get("RabbitExhangeType", "direct")
 
 
 def _load_json(path):

rabbit_repo.py

@@ -13,14 +13,14 @@ from utils import to_json, json_compress_str
 class RabbitRepo(RabbitBase):
     def __init__(self, external_source: str):
         super().__init__(exchange_type_resolver=self._resolve_type)
-        self._source = external_source  # like SystemUrl.ExternalUrl
+        self._source = external_source
 
     def _resolve_type(self, exch: str) -> str:
-        # longest prefix wins (like your .NET mapping)
+        # 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 settings.RABBIT_EXCHANGE_TYPE
+        return "fanout"  # Default for outbound
 
     async def publish(self, exchange: str, obj: Any, routing_key: str = "") -> None:
         ex = await self.ensure_exchange(exchange)