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

Added tests for automatic actor migration when node is shut down.

Browse source 
Updated to modified version of ZkClient (0.3, forked and fixed to allow interrupting connection retry).

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2011-06-26 15:04:11 +02:00
parent 15addf2b87
commit 7a5c95e44d
13 changed files with 145 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster/src/main/scala/akka/cluster/Cluster.scala
View file

@ -1354,7 +1354,7 @@ class DefaultClusterNode private[akka] (
}
// FIXME makes use of automaticMigrationFromFailedNodes method, why is it not used?
private[cluster] def automaticMigrationFromFailedNodes](currentSetOfClusterNodes: List[String]) {
private[cluster] def automaticMigrationFromFailedNodes(currentSetOfClusterNodes: List[String]) {
connectToAllNewlyArrivedMembershipNodesInCluster()
findFailedNodes(currentSetOfClusterNodes).foreach { failedNodeName ⇒