[akka 1.1.2] - réponse asynchrone bloquante Actor [Résolu]

[kaljerhom]

Bonjour,

J'envoi un message à un 'actor akka' et j'attend une réponse à cet envoi en utilisant la méthode '!!!'.

Le code de mon acteur

Code :

1
2
3
4
5
6
7
 
class MyActor entends Actor {
   def receive = {
      case "message" => "réponse"
      case _ => println("pas le bon message")
   }
}

Le code appelant (un TU)

Code :

1
2
3
4
5
6
7
 
def test() {
   val myActor = Actor.actorOf(new MyActor()).start()
   val f: Future[String] = myActor !!! "message"
   val content = f.get
   content should not be (null)
}

Mon souci est que quand je lance le test, je reçois une

akka.dispatch.FutureTimeoutException : Futures timed out after [5000] milliseconds

L'actor scala reçoit bien le message mais l'appelant lui ne reçoit pas de réponse.
Voyez vous quelque chose dans mon code que j'aurais oublié ?

Merci d'avance pour vos réponses.

[kaljerhom]

Bon bah j'ai trouvé tout seul.
La réponse est qu'il faut peut être dire à l'acteur qu'il doit répondre (ca semble logique ).

Du coup le code de l'acteur devient :

Code :

1
2
3
4
5
6
7
 
class MyActor entends Actor {
   def receive = {
      case "message" => self.channel ! "réponse"
      case _ => println("pas le bon message")
   }
}

voila.