Ποιος πρέπει να διαβάζει τα αποτελέσματα από την ουρά, να αποθηκεύει μηνύματα και συνομιλίες σε βάσεις δεδομένων και να στέλνει δεδομένα σε ροή σε μια ανοιχτή σύνδεση SSE;