Exchange и очереди

Exchange

Все сервисы используют единый exchange.

Параметр	Значение
Имя	estate_kit.events
Тип	topic
Durable	Да

Exchange объявляется каждым сервисом при запуске (exchange_declare с durable=True). Повторное объявление с теми же параметрами безопасно.

Очереди

Очередь	Сервис	Routing key	Описание
mls_bot.events	MLS Bot	#	Все сообщения — фильтрация по event_type в коде
property_review_decisions	API	property.review.decision	Решения менеджера по объектам
registration_decisions	API	tenant.registration.decision	Решения менеджера по регистрациям
data_change_decisions	API	tenant.data-change.decision	Решения менеджера по изменению данных
Все очереди — durable=True.

Сообщения по сервисам

MLS Bot

Направление	Сообщение	Описание
← Получает	property.review.request	Объект на модерацию
→ Отправляет	property.review.decision	Решение менеджера по объекту
← Получает	tenant.registration.request	Заявка на регистрацию
→ Отправляет	tenant.registration.decision	Решение по регистрации
← Получает	tenant.registration.cancelled	Отмена заявки на регистрацию
← Получает	tenant.data-change.request	Заявка на изменение данных
→ Отправляет	tenant.data-change.decision	Решение по изменению данных

API

Направление	Сообщение	Описание
→ Отправляет	property.review.request	Объект на модерацию
← Получает	property.review.decision	Решение менеджера по объекту
→ Отправляет	tenant.registration.request	Заявка на регистрацию
← Получает	tenant.registration.decision	Решение по регистрации
→ Отправляет	tenant.registration.cancelled	Отмена заявки на регистрацию
→ Отправляет	tenant.data-change.request	Заявка на изменение данных
← Получает	tenant.data-change.decision	Решение по изменению данных

Routing keys

Routing key в exchange topic поддерживает паттерны:

• # — все сообщения
• property.* — все сообщения с префиксом property
• mls.* — все сообщения MLS-каталога

Полный список routing keys

Routing key	Направление	Publisher → Consumer
property.review.request	API → Bot	Объект на модерацию
property.review.decision	Bot → API	Решение менеджера по объекту
tenant.registration.request	API → Bot	Заявка на регистрацию
tenant.registration.decision	Bot → API	Решение по регистрации
tenant.registration.cancelled	API → Bot	Отмена заявки на регистрацию
tenant.data-change.request	API → Bot	Заявка на изменение данных
tenant.data-change.decision	Bot → API	Решение по изменению данных