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

Additional coordination of shutdown in ClusterDeathWatchSpec, see #3255

Browse source 
* Added testconductor shutdown of actor system
* Renamed previous shutdown to exit
This commit is contained in:
Patrik Nordwall 2013-04-23 16:44:14 +02:00
parent b2494819d9
commit 19283207ff
20 changed files with 62 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala
View file

@ -795,7 +795,7 @@ abstract class StressSpec
runOn(roles.head) {
if (shutdown) {
log.info("Shutting down [{}]", removeAddress)
testConductor.shutdown(removeRole, 0).await
testConductor.exit(removeRole, 0).await
}
}
awaitMembersUp(currentRoles.size, timeout = remaining)
@ -828,7 +828,7 @@ abstract class StressSpec
runOn(roles.head) {
if (shutdown) removeRoles.foreach { r ⇒
log.info("Shutting down [{}]", address(r))
testConductor.shutdown(r, 0).await
testConductor.exit(r, 0).await
}
}
awaitMembersUp(currentRoles.size, timeout = remaining)