- Получение события: Продюсер создаёт событие
. Оно доставляется в Mediator (строка 54).OrderPlaced - Маршрутизация команд: В Mediator прописана бизнес-логика. Он отправляет команду
в модуль склада (строка 12).CheckInventory - Реакция: Когда склад завершает проверку, он генерирует событие
(строка 27).InventoryChecked - Продолжение оркестрации: Mediator получает
и инициирует следующую команду —InventoryChecked(строка 13, строка 33, строка 14).ProcessPayment
Пример простейшего In-Memory Оркестратора на Python
Python
import queue import time import threading # Общая очередь событий event_queue = queue.Queue()