Fixing ask/? for the routers so that tests pass and stuff

2011-10-27 18:04:12 +02:00 · 2011-10-27 18:04:12 +02:00 · c998485865
commit c998485865
parent e71d9f79f9
4 changed files with 32 additions and 29 deletions
--- a/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala
+++ b/akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala
@ -194,15 +194,9 @@ class RoutingSpec extends AkkaSpec {
        }
      })

-      val props = RoutedProps().withRoundRobinRouter.withLocalConnections(List(connection1))
-      val actor = app.actorOf(props, "foo")
+      val actor = app.actorOf(RoutedProps().withRoundRobinRouter.withLocalConnections(List(connection1)), "foo")

-      try {
-        actor ? Broadcast(1)
-        fail()
-      } catch {
-        case e: RoutingException ⇒
-      }
+      intercept[RoutingException] { actor ? Broadcast(1) }

      actor ! "end"
      doneLatch.await(5, TimeUnit.SECONDS) must be(true)