[akka 1.1.2] - réponse asynchrone bloquante Actor

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

Citation:

---

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.

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 8-) ).

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.