Merge branch 'master' into wip-camel-java-docs
This commit is contained in:
commit
4dbb507793
2 changed files with 11 additions and 2 deletions
|
|
@ -153,6 +153,15 @@ class RoutingSpec extends AkkaSpec(RoutingSpec.config) with DefaultTimeout with
|
||||||
expectMsgType[RouterRoutees].routees.head ! Kill
|
expectMsgType[RouterRoutees].routees.head ! Kill
|
||||||
}
|
}
|
||||||
expectMsgType[ActorKilledException]
|
expectMsgType[ActorKilledException]
|
||||||
|
|
||||||
|
//#supervision
|
||||||
|
|
||||||
|
val router2 = system.actorOf(Props.empty.withRouter(RoundRobinRouter(1).withSupervisorStrategy(escalator)))
|
||||||
|
router2 ! CurrentRoutees
|
||||||
|
EventFilter[ActorKilledException](occurrences = 2) intercept {
|
||||||
|
expectMsgType[RouterRoutees].routees.head ! Kill
|
||||||
|
}
|
||||||
|
expectMsgType[ActorKilledException]
|
||||||
}
|
}
|
||||||
|
|
||||||
"default to all-for-one-always-escalate strategy" in {
|
"default to all-for-one-always-escalate strategy" in {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue