Who should read results from the queue, save messages and chats to databases, and send streaming data to an open SSE connection?