Qui doit lire les résultats de la file d'attente, sauvegarder les messages et les chats dans des bases de données, et envoyer des données en streaming à une connexion SSE ouverte?