Merge pull request #15168 from akka/wip-readd-BalancingPool-test-∂π
=act add one more test to routing.BalancingSpec
This commit is contained in:
commit
98463b2f5e
1 changed files with 14 additions and 0 deletions
|
|
@ -37,6 +37,13 @@ class BalancingSpec extends AkkaSpec(
|
||||||
attempt-teamwork = on
|
attempt-teamwork = on
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
/balancingPool-3 {
|
||||||
|
router = balancing-pool
|
||||||
|
nr-of-instances = 5
|
||||||
|
pool-dispatcher {
|
||||||
|
attempt-teamwork = on
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
""") with ImplicitSender with BeforeAndAfterEach {
|
""") with ImplicitSender with BeforeAndAfterEach {
|
||||||
import BalancingSpec._
|
import BalancingSpec._
|
||||||
|
|
@ -84,5 +91,12 @@ class BalancingSpec extends AkkaSpec(
|
||||||
test(pool, latch)
|
test(pool, latch)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
"deliver messages in a balancing fashion when overridden in config" in {
|
||||||
|
val latch = TestLatch(1)
|
||||||
|
val pool = system.actorOf(BalancingPool(1).props(routeeProps =
|
||||||
|
Props(classOf[Worker], latch)), name = "balancingPool-3")
|
||||||
|
test(pool, latch)
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue