Quem deve ler os resultados da fila, guardar mensagens e chats em bases de dados, e enviar dados em streaming para uma conexão SSE aberta?