У меня есть два узла в кластере Akka. Я подписываюсь на все ClusterDomainEvent кластера с помощью: cluster.subscribe( self, InitialStateAsEvents, classOf[ClusterDomainEvent]) Когда один из двух узлов не работает, я получаю...

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

Насколько я понимаю с akka-cluster, внешний узел получает запрос и отправляет задание одному из внутренних узлов для его выполнения. Я хочу выяснить для целей отладки, как узнать, какой из серверных узлов выполняет задание? Предоставляет ли akka...

Я использую Akka Distributed Pub/Sub и имею одного издателя и подписчика. Мой издатель намного быстрее, чем подписчик. Есть ли способ замедлить работу издателя после определенного момента? Код издателя: public class Publisher extends...

Недавно мы перешли на Nitrogen-SR3 и настроили кластеризацию с 2 узлами. Когда мы перезапускаем узел (т. е. после восстановления после сбоя), мы наблюдаем следующее исключение в karaf.log, и узел не может присоединиться к кластеру. Любая помощь...