Quarantine from ClusterRemoteWatcher also, see #2993

* This was an oversight in previous pull request
2013-04-18 16:54:57 +02:00 · 2013-04-18 16:54:57 +02:00 · 58bd0a1460
commit 58bd0a1460
parent 09b55a2be3
2 changed files with 6 additions and 3 deletions
--- a/akka-cluster/src/main/scala/akka/cluster/ClusterRemoteWatcher.scala
+++ b/akka-cluster/src/main/scala/akka/cluster/ClusterRemoteWatcher.scala
@ -82,6 +82,7 @@ private[cluster] class ClusterRemoteWatcher(
      takeOverResponsibility(m.address)
    case MemberRemoved(m) ⇒
      clusterNodes -= m.address
+      quarantine(m.address, m.uniqueAddress.uid)
      publishAddressTerminated(m.address)
  }