Я реализую систему CQRS с постоянством Akka и пытаюсь понять бит ответа на запрос CQRS. На SO есть несколько ответов о том, как отправить ответ обратно клиенту, и эта статья также упоминает несколько хороших шаблонов. Но вместо того, чтобы...

Как мне структурировать своих актеров в постоянном Akka (Eventsourcing/CQRS)? Иерархический Параллельно У меня есть эти объекты домена в моем приложении электронной коммерции Пользователь - пользователь может создать учетную запись...

Я запутался в применимости Akka Persistence и постоянных актеров, когда мне следует использовать постоянного актера? Взяв, например, из модуля корзины данного приложения для покупок, будет ли сеанс корзины каждого пользователя постоянным...

У меня стойкий актер. Когда он запускается в первый раз (база данных пуста), я сохраняю некоторые исходные данные. Но состояние не обновляется, как я ожидал. Он обновляется только после обработки первого сообщения. Как я могу заставить актера...

Акка предоставляет Постоянный субъект с доставкой сообщения хотя бы один раз ( ссылка ) Постоянный FSM ( ссылка ) Могу ли я смешать два? Я хочу иметь возможность поддерживать постоянный конечный автомат, но также инициировать события...

Я пробую пример «hello-world» с akka-persistence, поддерживаемым MongoDb, используя этот открытый исходный код, https://github.com/scullxbones/akka-persistence-mongo/tree/master/rxmongo/src . Ниже мой код. Однако, когда я запускаю приложение, я...

В настоящее время у меня есть служба, основанная на событиях, поддерживаемая Akka и Cassandra. Это система торгов под названием AuctionService, и в какой-то момент мне нужно получить последнее событие ставки с именем BiddenOnLot . Для этого я...

Как мы можем запросить старый снимок в akka-persistence? Я вижу, что у SnapshotStore есть сообщение LoadSnapshot , которое доступно в частном порядке, но недоступно для других вызовов. есть интерфейс в snapshotter -> loadSnapshot но...

Я играю с разными плагинами akka-persistence, чтобы сравнить доступные варианты. Теперь я могу успешно работать с плагинами in-memory и leveldb, но столкнулся с некоторым исключением времени выполнения с плагином cassandra. akka { persistence...

Я использую EventStore в качестве ReadJournal и akka-persistence API для создания постоянного представления. Проблема, с которой я сталкиваюсь, заключается в том, что я не вижу теги в графическом интерфейсе EventStore после сохранения...

Я использую OpenDaylight и пытаюсь заменить распределенную базу данных по умолчанию на Apache Ignite. Я использую банку, полученную с помощью исходного кода здесь: https://github.com/Romeh/akka-persistance-ignite и развернул его в karaf-контейнере...

Как я могу загрузить только актера, если он ранее был официально создан в соответствии с правилами домена? Все, что я видел, используя actorOf и постоянство, всегда создает пустой экземпляр, а затем применяет [возможно пустой] набор событий,...

Я тестирую постоянного актера Akka. Для этого я использую сохраняемость в памяти. Тест начинается, и я вижу, как актер восстанавливает сохраненные сообщения. Я пробую следующее: Я отправляю актору сообщение, которое запускает...