У меня есть служба REST, в которой несколько действующих лиц координируют свои действия. Данные хранятся в postgresDB. Согласно новой системе актеров akka 2.6 для типизированных актеров, https://doc.akka.io/docs/akka/2.6/typed/actors.html, нам нужно передавать сообщения между акторами и на основе сообщений, которые реагируют актеры. Например, я должен делать операции CRUD для пользовательских категорий. Поток запросов: Контроллер -> Актер 1 -> Актер 2 -> DAO Поток ответов: DAO -> Актер 2 -> Актер 1 -> Контроллер
Исходя из этого сценария, у меня есть несколько вопросов :
1 Должны ли мы иметь разные onMessages для каждого актера?
return newReceiveBuilder().onMessage(GetCategories.class, this::onGet)
.onMessage(AddCategories.class, this::onAdd)
.build();
Как контроллер будет вызывать актера 1?
Нужен ли нам новый POJO для каждого передаваемого сообщения? Например, GetCategory, AddCategory.
Не слишком ли много настроек кода в каждом актере?