Renvoyer le message "init" sur le redémarrage de l'acteur Akka

Question

J'ai un enfant "consommateur" acteur qui se connecte à un flux de données externe, analyse ses messages et les transmet plus loin dans l'application. Ce système "producteur" a une architecture pub-sub, mais ne restaure pas les abonnements après la reconnexion. Actuellement, je stocke ces abonnements dans l'acteur parent et je les renvoie dans le superviseur, mais le problème est que pendant le redémarrage de l'enfant, ils sont redirigés vers la file d'attente des lettres mortes. J'aurais pu essayer de les programmer à parent après un certain délai, mais cela peut interférer avec l'ordre d'abonnement, ce qui est important.

Alors, comment envoyer ces messages de "réabonnement" à l'enfant pendant qu'il redémarre?

Answer 1

Vous pouvez utiliser Restart Hooks (http://doc.akka.io/docs/akka/snapshot/scala/actors.html#Restart_Hooks): preRestart et postRestart api. Sur preRestart sur l'acteur enfant, vous devez informer le superviseur que l'acteur enfant va redémarrer et que le superviseur doit suspendre l'envoi du message. Sur postRestart sur l'acteur enfant, vous devez informer le superviseur que l'enfant est disponible et que le superviseur doit reprendre l'envoi du message.

Answer 2

Vous pouvez vous abonner à des lettres mortes avec

context.system.eventStream.subscribe(myListenerActorRef, classOf[DeadLetter]) 
... 
def receive = { 
    case DeadLetter(msg, from, to) => 
    //Do my custom stuff here 
} 

, magasin et les envoyer à nouveau.