Я реализую приложение EventSourcing, которое обрабатывает большое количество исходных и производных точек данных. Короче говоря, у нас есть PersistentActor , функционирующий как агрегированный корень , принимающий команды: UpdateValue(name,...

В методе приема постоянного актора я получаю группу событий, которые хочу сохранить, и только после того, как все события сохраняются, снова обновляю свое состояние. Как я могу это сделать? def receive: Receive = { ... case NewEvents(events)...

Какой readJournalPluginId следует использовать с плагином журнала inmem? "akka.persistence.journal.plugin" -> "akka.persistence.journal.inmem" PersistenceQuery(system).readJournalFor[???](???)

При перезапуске системы вызов context.children() возвращает ноль дочерних элементов для определенного родителя. Перед перезапуском context.children() возвращал фактическое количество дочерних элементов, которые были у родителя. Может кто-нибудь,...

В настоящее время мы проводим некоторое исследование CQRS и Event Sourcing и обнаружили две основные структуры, которые решают эти две проблемы: Axon Framework и Eventuate . Оба они продолжают развиваться, а Eventuate сейчас более активно...

Ищу немного мудрого совета, пожалуйста. У меня есть простой FSM управления заказами с полдюжиной состояний. Я настраиваю свою систему на поддержку 10 000 заказов в час пик. Каждому заказу потребуется от 10 до 120 секунд для прохождения FSM....

Мы используем версию Opendaylight Nitrogen-SR3. Мы хотим поддерживать больше сетевых элементов, и во время нашего тестирования мы обнаружили отсутствие «осколков». При анализе этой проблемы мы заметили, что сегменты отсутствуют, так как LevelDB не...

Я играю с Akka Typed (версия 2.6.0) и источником событий, и мне удалось заставить его работать с плагином LevelDB. Поскольку я намерен использовать кластерную среду, LevelDB не будет работать с такой настройкой, поскольку он хранит данные в...