Frontend → POST /episodes/{id}/ai-recommendations/generate ↓ Spring Boot (202 ACCEPTED) - Creates snapshot + run (PROCESSING) - Publishes RabbitMQRecommendationMessage ↓ (pji.ai.exchange / ai.recommendation.generate) RabbitMQ ↓ (pji.ai.recommendation.queue) RAG Worker (Python) - Runs completeness check - Runs RAG pipeline + LLM - Publishes result ↓ (pji.ai.exchange / ai.recommendation.result) RabbitMQ ↓ (pji.ai.recommendation.result.queue) Spring Boot RabbitMQConsumer - Updates run status (SUCCESS/FAILED) - Saves items + citations ↓ Frontend ← GET /ai-recommendations/runs/{runId} (polling)