Я использую Akka FSM в своем проекте и собираюсь добавить настойчивость. Простое решение - использовать Persistent FSM ( https://doc.akka.io/docs/akka/current/persistence-fsm.html ). Однако в официальной документации существует предупреждение...

Я только что столкнулся с проблемой в своей работе, которая соответствует https://github.com/akka/akka/issues/26899 . Как я могу написать типизированное поведение, где я могу получить case (reason: Throwable, message: Option[Any]) =>...

Я не понимаю, почему я получаю перегруженную ошибку внутри timers.startTimerWithFixedDelay. Я добавил 3 параметра, чтобы убедиться, что выбран правильный метод, но, похоже, он также находит метод всего с 2 параметрами очень привлекательным....

Может ли кто-нибудь поделиться минимальным примером ведения журнала с типизированным akka? В akka classic я использовал LoggingReceive и установил в src/main/resources/application.conf akka { loglevel = DEBUG actor { debug {...

В настоящее время я пытаюсь заставить двух разных постоянных актеров общаться друг с другом. Особенно: Given an Actor A exists When an Actor B is spawned Then Actor B must have a reference to Actor A And Actor B must be able to continuously send...

Я пытаюсь создать почтовый ящик с настраиваемым приоритетом с типом akka, который расставляет приоритеты для сообщений в зависимости от типа сообщения. Ниже приведен мой код, который создает актера и отправляет ему сообщения. Однако сообщения...

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

Я экспериментирую с типизированным Akka. У меня есть фиктивный актер, который имитирует ненадежного работника: import akka.actor.typed.Behavior import akka.actor.typed.receptionist.{Receptionist, ServiceKey} import...