Отправка сообщения всем действующим лицам в системе ActorSystem

Question

Можно ли отправить сообщение всем актерам в актерской системе? Я рассматривал пример Broadcast router, но это настолько маргинально, что я не могу понять, как динамически добавлять актеров в маршрутизатор.

Мы используем scala для akka.

Спасибо!

Answer 1

system.actorSelection("/user/*") ! msg 

Выбирает всех детей опекуна и посылает им сообщ.

Answer 2

Если вы хотите отправить сообщение всем актер, который динамически создан, вы можете использовать eventBus

Лично я использую system.eventStream для моего случая.

От актера, вы можете отправить всем:

context.system.eventStream.publish(StatisticsMessage()) 

или непосредственно с системой.

актер должен подписаться с:

context.system.eventStream.subscribe 

Я простирается от:

trait SubscriberActor extends Actor { 

    def subscribedClasses: Seq[Class[_]] 

    override def preStart() { 
    super.preStart() 
    subscribedClasses.foreach(this.context.system.eventStream.subscribe(this.self, _)) 
    } 

    override def postStop() { 
    subscribedClasses.foreach(this.context.system.eventStream.unsubscribe(this.self, _)) 
    super.postStop() 
    } 
}