Removed racy test. See #1495
This commit is contained in:
parent
5aa4784ea2
commit
f67a50074b
1 changed files with 14 additions and 5 deletions
|
|
@ -10,6 +10,7 @@ import java.util.concurrent.{ CountDownLatch, TimeUnit }
|
||||||
import akka.testkit._
|
import akka.testkit._
|
||||||
import akka.util.duration._
|
import akka.util.duration._
|
||||||
import akka.dispatch.Await
|
import akka.dispatch.Await
|
||||||
|
import com.typesafe.config.ConfigFactory
|
||||||
|
|
||||||
object RoutingSpec {
|
object RoutingSpec {
|
||||||
|
|
||||||
|
|
@ -29,7 +30,18 @@ object RoutingSpec {
|
||||||
}
|
}
|
||||||
|
|
||||||
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
|
||||||
class RoutingSpec extends AkkaSpec with DefaultTimeout with ImplicitSender {
|
class RoutingSpec extends AkkaSpec(ConfigFactory.parseString("""
|
||||||
|
akka {
|
||||||
|
actor {
|
||||||
|
deployment {
|
||||||
|
/a1 {
|
||||||
|
router = round-robin
|
||||||
|
nr-of-instances = 3
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
""")) with DefaultTimeout with ImplicitSender {
|
||||||
|
|
||||||
val impl = system.asInstanceOf[ActorSystemImpl]
|
val impl = system.asInstanceOf[ActorSystemImpl]
|
||||||
|
|
||||||
|
|
@ -68,14 +80,11 @@ class RoutingSpec extends AkkaSpec with DefaultTimeout with ImplicitSender {
|
||||||
val routee3 = context.actorOf(Props[TestActor], "routee3")
|
val routee3 = context.actorOf(Props[TestActor], "routee3")
|
||||||
val router = context.actorOf(Props[TestActor].withRouter(ScatterGatherFirstCompletedRouter(routees = List(routee1, routee2, routee3))))
|
val router = context.actorOf(Props[TestActor].withRouter(ScatterGatherFirstCompletedRouter(routees = List(routee1, routee2, routee3))))
|
||||||
|
|
||||||
// Stop one of the routees - which should exclude it from the router's list of active routees
|
|
||||||
routee3 ! PoisonPill
|
|
||||||
|
|
||||||
def receive = {
|
def receive = {
|
||||||
case RouterRoutees(iterable) ⇒
|
case RouterRoutees(iterable) ⇒
|
||||||
iterable.exists(_.path.name == "routee1") must be(true)
|
iterable.exists(_.path.name == "routee1") must be(true)
|
||||||
iterable.exists(_.path.name == "routee2") must be(true)
|
iterable.exists(_.path.name == "routee2") must be(true)
|
||||||
iterable.exists(_.path.name == "routee3") must be(false)
|
iterable.exists(_.path.name == "routee3") must be(true)
|
||||||
doneLatch.countDown()
|
doneLatch.countDown()
|
||||||
case "doIt" ⇒
|
case "doIt" ⇒
|
||||||
router ! CurrentRoutees
|
router ! CurrentRoutees
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue