raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

1. Removed implicit scoped timeout in ? method.

Browse source 
Reason: 'pingPongActor.?(Ping)(timeout = TimeoutMillis)' breaks old user code and is so ugly. It is not worth it. Now user write (as he used to): 'pingPongActor ? (Ping, TimeoutMillis)'
2. Fixed broken Cluster communication
3. Added constructor with only String arg for UnhandledMessageException to allow client instantiation of remote exception

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2011-06-14 14:26:13 +02:00
parent e18cc7bac6
commit 26500bed09
16 changed files with 55 additions and 59 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-tutorials/akka-tutorial-second/src/main/scala/Pi.scala
View file

@ -104,7 +104,7 @@ object Pi extends App {
val start = now
//send calculate message
master.?(Calculate)(timeout = Actor.Timeout(60000)).
master.?(Calculate, Actor.Timeout(60000)).
await.resultOrException match {//wait for the result, with a 60 seconds timeout
case Some(pi) =>
EventHandler.info(this, "\n\tPi estimate: \t\t%s\n\tCalculation time: \t%s millis".format(pi, (now - start)))