Envoyer un message à tous les acteurs dans un ActorSystem

Question

Est-il possible d'envoyer un message à tous les acteurs dans un système d'acteur? J'ai regardé l'exemple Broadcast router, mais c'est tellement marginal que je ne peux pas comprendre comment j'ajoute dynamiquement des acteurs au routeur.

Nous utilisons scala pour akka.

Merci!

Answer 1

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

Sélectionne tous les enfants du tuteur et les envoie msg.

Answer 2

Si vous voulez envoyer un message à tous les acteurs qui sont créés dynamiquement, vous pouvez utiliser eventBus

J'utilise personnellement system.eventStream pour mon cas.

d'un acteur, vous pouvez envoyer à tout le monde:

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

ou directement avec le système.

acteur

doit souscrire à:

context.system.eventStream.subscribe 

Je Prolonge de:

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() 
    } 
}