Любая идея, почему я получаю следующую ошибку после добавления Akka в зависимости от моей библиотеки и выполнения задачи test ? Uncaught error from thread [reactivemongo-akka.actor.default-dispatcher-4] shutting down JVM since...

У меня странное поведение при использовании context.become в PersistentActor (не уверен, что постоянство имеет какое-либо отношение к причине проблемы). Мой код выглядит примерно так: class MyActor extends PersistentActor { import context._...

Мне нужно сериализовать события akka в json. На основе « Какую библиотеку JSON использовать в Scala? " я попытался несколько библиотек. Поскольку мой сериализатор ничего не должен знать обо всех моих конкретных событиях, события, состоящие из...

Я исследовал экспериментальный модуль Akka Persistence Query и очень заинтересован в реализации пользовательского журнала чтения для своего приложения. В документации описаны два основных вида запросов: те, которые возвращают текущее состояние...

В настоящее время я разрабатываю приложение с использованием платформы Play-Scala и актера akka для отправки электронной почты, когда происходит действие CRUD с базой данных. У меня проблема при перезапуске сервера. Любой способ перезагрузить...

Учитывая Event-A , Event-B , Event-C , которые поступают (возможно, не по порядку) в течение нескольких дней друг от друга, я хочу запустить обработку для создания производной Event-ABC , как только я узнаю, что у меня есть все события в наборе....

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

Я оцениваю, следует ли использовать Akka и akka Permanent в качестве ключевого инструментария определенного проекта, в котором есть сложный фоновый процесс (может запускаться Quartz в фиксированное время в день). Фоновый процесс будет связываться...

Я пытаюсь создать систему на основе akka, которая будет периодически (каждые 15 секунд) отправлять запрос REST, выполнять некоторую фильтрацию, некоторую очистку данных и проверку полученных данных и сохранять их в HDFS. Ниже приведен код, который...

Я тестирую постоянного актера (который хранит сущность) с помощью набора тестов: val testActor = system.actorOf((IMPersistentActor.props("id1"))) testActor ! AddElementCommand(refVal) //...

В некоторых примерах akka-backoff я вижу, что используется onStop , а в некоторых других я вижу, что используется onFailure , но я не вижу примера, где оба используются для отсрочки, я что-то упустил? Разве не принято откладывать как onStop, так и...

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

Я просматривал пример сегментирования и заметил, что имя родителя используется как часть PersistenceId? PersistenceId = Context.Parent.Path.Name + "-" + Self.Path.Name; Мои вопросы: Является ли имя родителя ShardId? Какова цель...

У меня есть постоянный актер, который может получать команду одного типа Persist(event) , где событие имеет тип trait Event (существует множество его реализаций). И в случае успеха это возвращает Persisted(event) отправителю. Само событие...

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