Как лучше всего реализовать протокол запроса / ответа с использованием akka и scala?

Я изучал, как я могу разработать распределенную архитектуру, которая реализует протокол запрос / ответ с использованием Concep t параллелизма через акторов.

Я пришел к выводу, что лучший способ сделать это - создать систему ответа с синхронной обработкой Futures / Promises и вскоре после ответа оставить открытый канал для получения уведомлений.

Таким образом, архитектура, которая будет работать точно так же, как входящие сообщения.

У нее есть некоторые проблемы.

Таким образом, мне пришлось бы поддерживать две конечные точки (действующих лиц на двух уровнях)?

Проблема: Модуль просмотра запрашивает обработку определенного элемента. Она отправляет эту команду для обработки через RemoteActor на сервере приложений. Этот сервер должен немедленно вернуть обещание, что он уведомит вас, когда элемент будет обработан. После этого модуль представления будет ожидать уведомления о завершении обработки.

Как вы видите эту проблему?

Я использую Scala, Akka и Google Guice.

Я считаю, что это общая проблема, которая каждый может воспользоваться их решениями. Извините, если я нарушаю условия сайта stackoverflow.

Заранее спасибо