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

У меня есть Actor , который создает детей, используя Router . Когда один из детей терпит неудачу. Меня уведомляют в стратегии о сбое. Однако Actor не перезапускается сам по себе. private static SupervisorStrategy strategy = new...

У меня возникла проблема с актером-супервайзером Akka. Когда дочерний актор выдает исключение в методе onFailure будущего результата, супервизор не обрабатывает ошибку (я хочу перезапустить дочерний элемент в случае ConnectException). Я использую...

Я пытаюсь разработать приложение с использованием супервизоров Futures и Akka, но когда Future возвращает сбой актеру, его супервизор не получает исключения. Вот мой код. 1) Актер-супервайзер class TransaccionActorSupervisor() extends Actor...

У меня есть отношения родитель -> дочерний субъект для загрузки файлов в Dropbox. Отношение состоит из актера-супервизора и актера загрузки. Субъект супервизора определяет стратегию супервизора для субъекта загрузки. Поэтому, если загрузка в...

Я новичок в Akka (Java lib, v2.3.9). Я пытаюсь следовать рекомендациям по иерархии супервизоров , но поскольку это мое первое приложение Akka, я где-то сталкиваюсь с ментальным барьером. В моем первом приложении Akka (на самом деле это...

Обратите внимание: я разработчик Java и практически не знаю Scala (к сожалению). Я бы попросил, чтобы любые примеры кода, представленные в ответе, использовали Java API Akka. Я новичок в Akka и актерах и пытаюсь настроить довольно простую...

Я новичок в Akka и пытаюсь понять SupervisorStrategies и завершение дочернего актера. У меня есть несколько очень похожих опасений. Во-первых, мое понимание заключается в том, что если актер создает другого актера (через context.actorOf(...)...

Я создаю одного дочернего актера для одного родителя. Мой дочерний актер выполняет некоторую бизнес-логику и возвращает значение в scala Future. Когда я отправляю Future сообщение своему родителю, я не могу перехватить свое будущее сообщение....

Предположим, что супервизор определил определенную стратегию: private static SupervisorStrategy strategy = new OneForOneStrategy(10, Duration.create("1 minute"), DeciderBuilder. match(Exception.class, e ->...

У меня возникла проблема при попытке использовать маршрутизаторы akka.net. Мой циклический маршрутизатор не завершает работу после передачи сообщения PoisonPill, если в маршруте есть исключение, которое обрабатывается с помощью supervisorstrategy....

У меня есть актер с использованием тайника. Иногда при сбое теряются все спрятанные сообщения. Я обнаружил, что это зависит от того, какую логику контроля я использую. Я написал простой пример. Актер с заначкой: case object WrongMessage...

Я пытаюсь создать кластер Akka Sharding. Я хочу использовать режим только прокси на одном из узлов только для маршрутизации сообщения в области сегментов. Я получаю следующее предупреждение: [WARN] [02/11/2019 17:04:17.819]...

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