Akka - superviseur de routeurStrategy- comment envoyer un message au routeur sur l'événement

Question

Salut Je veux mettre en œuvre une stratégie de routeur qui sur un événement enverra un message au routeur, mais je ne sais pas comment obtenir une référence au routeur dans la mise en œuvre de la stratégie.

C'est ce que je suis en train de faire:

val router = system.actorOf(RoundRobinPool(5, supervisorStrategy = OneForOneStrategy(){ 
     case _: ActorKilledException => Escalate 
     case _: ActorInitializationException => Escalate 
     case _ => self ! SomeMsg(); Restart 
    }).props(Props(classOf[MyClass]))) 

Lorsque l'auto doit être le routeur ActorRef, mais l'auto n'est pas reconnu dans ce contexte.

Answer 1

Normalement, je ne crée le cas dans le routeur, mais en dehors

val workerRouter: ActorRef = context.actorOf(
    Props[Worker].withRouter(RoundRobinPool(nrOfWorkers)), name = "workerRouter") 

    val msgRouter: ActorRef = context.actorOf(
    Props[Worker].withRouter(RoundRobinPool(nrOfWorkers)), name = "msgRouter") 

Ensuite, dans ma fonction récepteur acteur

def receive: PartialFunction[Any, Unit] = { 
    case RunWorkersMsg => 
     workerRouter ! WorkMsg(i , numberOfElements) 
    case ResultMsg(value) => 
     msgRouter ! WorkMsg() 
    } 

Ici vous pouvez voir mon projet Akka avec un exemple https://github.com/politrons/Akka