Описание тега akka-supervision

Вопросы с тегом
В Akka супервизия описывает отношения зависимости между участниками: супервизор делегирует задачи подчиненным и поэтому должен реагировать на их сбои. Когда подчиненный обнаруживает сбой (т. Е. Генерирует исключение), он приостанавливает работу себя и всех своих подчиненных и отправляет сообщение своему супервизору, сигнализируя о сбое.
2 ответа

Akka - как родитель отправляет сообщение ребенку после того, как у ребенка было исключение

Если у меня есть parent актер, который отправляет одно сообщение за раз child актер. Когда дочерний процесс завершает обработку текущего сообщения, он уведомляет родителя, что, в свою очередь, отправит новое сообщение дочернему элементу. Чтобы сохра…
17 авг '17 в 09:48
1 ответ

Акка: Как объединить OneForOneStrategy и AllForOneStrategy

Если я определю стратегию супервизора для актера в Scala, как я могу использовать оба OneForOneStrategy и AllForOneStrategy? Есть ли простой способ объединить их или мне нужно определить пользовательский SupervisorStrategy? Вот пример: class MyActor…
06 июл '17 в 09:41
1 ответ

Акка - как сказать системе, что делать после достижения максимальных попыток стратегии?

Предполагая, супервизор актер определил определенную стратегию: private static SupervisorStrategy strategy = new OneForOneStrategy(10, Duration.create("1 minute"), DeciderBuilder. match(Exception.class, e -> resume()). matchAny(o -> escalate()…
16 авг '17 в 06:00
1 ответ

Предотвратить akka actor от перезапуска дочернего актера

Я пытаюсь найти актера Worker не перезапускать своего дочернего актера SubWorker когда он перезапускается своим собственным руководителем Mngr, Я потерпел неудачу даже после переопределения preRestart() а также postRestart в Worker, Логи все еще пок…
11 дек '13 в 19:38
1 ответ

Akka: Пользовательские стратегии контроля akka не зарегистрированы с использованием Java

Я собираюсь исследовать Akka жизненный цикл и Akka стратегии надзора за актерами. Я создаю свои собственные исключения и переопределяю public SupervisorStrategy supervisorStrategy() метод изучения жизненного цикла акки и стратегии их восстановления.…
18 авг '16 в 12:47
1 ответ

Акка: рекомендации супервайзера по тестированию

Я очень новичок в Akka и используя Java чтобы запрограммировать мою систему. Определение проблемы - У меня есть TenantMonitor который, когда получает TenantMonitorMessage()начинается новый актер DiskMonitorActor,- DiskMonitorActor может потерпеть не…
02 май '15 в 20:37
1 ответ

Стратегия супервайзера Akka для разных типов актеров

Я использую Akka и хочу определить свою собственную стратегию надзора для актера User Guardian. Я определил два типа актеров, называемых TaskActor и MessageActor. Они созданы как актеры высшего уровня. Я хочу, чтобы пользователь-хранитель применил с…
30 май '15 в 16:01
0 ответов

Акка Кластер не может зарегистрироваться для координатора

Я пытаюсь создать кластер шардинга Акка. Я хочу использовать режим "только прокси" на одном из узлов, чтобы просто перенаправить сообщение в области сегментов. Я получаю следующее предупреждение: [WARN] [02/11/2019 17:04:17.819] [ClusterSystem-akka.…
11 фев '19 в 12:52
1 ответ

Akka-Java: невозможно получить сообщение Future в родительском объекте с использованием шаблона канала

Я создаю одного дочернего актера для одного из родителей. Мой детский актер выполняет некоторую бизнес-логику и возвращает значение в Scala Future. Когда я отправляю Future сообщение для моих родителей, я не могу поймать свое будущее сообщение. Ниже…
21 авг '16 в 05:46
2 ответа

Как отправить сообщение от Супервайзера Актеру после перезапуска Актера?

Требование? - Должен быть запущенный процесс (демон), который должен работать вечно- В случае каких-либо исключений его следует перезапустить, но если дважды произойдет сбой, не нужно предпринимать никаких попыток перезапуска. Проблема, с которой я …
30 май '15 в 23:11
0 ответов

Akka: тестирование стратегии контроля с TestProbes

Я тестирую актера, который порождает и координирует детей актеров. Для этого я заменил создание дочернего актера на TestProbes, которые используются для наблюдения и имитации обмена сообщениями. Однако я столкнулся с проблемой при попытке проверить …
06 окт '16 в 08:37
1 ответ

Актер супервизора Akka не обрабатывает исключение, когда дочерний актор создает исключение в onFailure of the future

У меня проблема с актером-супервайзером Акки. Когда дочерний субъект генерирует исключение в методе onFailure будущего результата, супервизор не обрабатывает ошибку (я хочу перезапустить дочерний элемент в случае исключения ConnectException). Я испо…
22 ноя '14 в 14:02
0 ответов

Какой должна быть стратегия надзора для AskTimeOutException

Я новичок в области надзора в akka. Я хочу знать, какая стратегия надзора хороша, когда мы получаем исключение тайм-аута запроса, что является более подходящим Перезапуск или Возобновление, вот пример кода class ActorA extends Actor{ override val su…
21 июн '16 в 06:37
2 ответа

Отправка обратно отправителю от супервизора в случае сбоя

У меня есть актер, который выступает в роли супервизора, но также должен "возвращать" данные вызывающей стороне, независимо от того, актер это или нет, это не должно иметь значения. Я прошу моего руководителя, давайте назовем его SV. SV обрабатывает…
08 дек '15 в 12:38
2 ответа

akka - делает одного актера дочерним для нескольких других акторов (в роутере)

Я не уверен, что это возможно - могу ли я сделать одного актера ребенком многих других актеров? Я, конечно, могу передать ссылку другим актерам, но мне нужен надзор, чтобы работать и в этом случае - это вообще возможно? например, вот пример с типизи…
11 сен '13 в 14:38
1 ответ

Акка: всегда ли DeathPactException является ошибкой программирования?

Я время от времени использую Akka.NET в своих проектах, поэтому я знаю технологию, могу с ней что-то делать, но не считаю себя экспертом. Хотя я использую.NET, на этот вопрос наверняка может ответить кто-то, знакомый с Akka в JVM. Недавно я наткнулс…
18 июл '18 в 09:23
1 ответ

Акка - Как перезапустить ребенка, порожденного роутером?

У меня есть Actor что создает детей, используя Router, Когда один из детей терпит неудачу. Меня предупреждают в старте о сбое. Тем не менее Actor не перезапускается сам по себе. private static SupervisorStrategy strategy = new OneForOneStrategy(10, …
18 ноя '14 в 12:37
1 ответ

Akka - дочерние акторы перезапускаются, когда родительский актер перезапускается

У меня есть иерархия одиночных актеров. Родитель контролирует и координирует детей. Мне нужно, чтобы дети-актеры работали после перезапуска координатора. Есть ли способ предотвратить перезапуск дочерних актеров при перезапуске их родителей, или я до…
18 ноя '15 в 21:28
1 ответ

Актер, контролируемый BackoffSupervisor, теряет спрятанные сообщения после перезапуска

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

Акка: как я могу поймать неудачу одного актера внутри другого (не дочернего) актера?

У меня есть два актера: ProcessManager, который обрабатывает некоторые процессы в системе (например, регистрация пользователя, покупка и т. Д.) Уведомитель - должен уведомлять пользователя, если в ProcessManager произошла какая-либо ошибка. Мне нужн…
20 июл '17 в 22:08