У меня есть актер, который создается при запуске приложения как дочерний элемент другого актера и получает сообщение один раз в день от родителя для выполнения операции по извлечению некоторых файлов с какого-либо SFTP-сервера. Теперь могут быть...

Akka Java здесь. У меня есть два актера, Parent и Child , где первый является родителем второго. Если Child выдает конкретное исключение (скажем, UnrulyTeenagerExcepton ), то поведение, которое я ищу, выглядит следующим образом: Parent...

Чтение документа Akka: http://doc.akka.io/docs/akka/2.2.3/AkkaScala.pdf его состояния в разделе 2.2.1 Hierarchical Structure The only prerequisite is to know that each actor has exactly one supervisor, which is the actor that created it. Но...

Я новичок в Akka, но мое понимание директивы Stop заключается в том, что она используется внутри директивы SupervisorStrategies , когда дочерний элемент должен считаться окончательно выведенным из строя, но есть способ справиться с полным...

Хотите перезапустить актера после исключения с предыдущим состоянием по стратегиям супервизора. Например Супервайзер актера сохраняет некоторые параметры от своих детей. Также супервизор имеет следующую стратегию: override val...

Я знаю, что можно перезапустить поток akka при ошибке с помощью стратегии наблюдения на ActorMaterialzer. val decider: Supervision.Decider = { case _: ArithmeticException => Supervision.Resume case _ =>...

Можно ли изменить стратегию супервайзера опекуна, чтобы изменить его настройки «Решающего» по умолчанию. Например, в настоящее время он обрабатывает ActorKilledExceptions, останавливая дочерние акторы. Как мы можем изменить способ обработки этих...

Я запускаю приложение Akka Streams Kafka, и я хочу включить стратегию наблюдения в потребителя потока, чтобы, если брокер выходит из строя, а потребитель потока умирает после тайм-аута остановки, супервизор может перезапустить потребителя. Вот мой...

У меня есть актер, который действует как супервизор, но также должен «возвращать» данные вызывающей стороне, независимо от того, является ли это актером или нет, это не имеет значения. Я прошу своего Супервайзера, назовем его С.В. SV...

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