¿Quién debe leer los resultados de la cola, guardar mensajes y chats en bases de datos, y enviar datos en streaming a una conexión SSE abierta?