Ignore possible state change while waiting for removal #25274

2018-06-27 09:06:32 +02:00 · 2018-06-27 09:06:32 +02:00 · 28746a4cfe
commit 28746a4cfe
parent 9075480747
1 changed files with 3 additions and 0 deletions
--- a/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala
+++ b/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala
@ -804,6 +804,9 @@ class ClusterSingletonManager(
    case Event(MemberRemoved(m, _), _) if m.uniqueAddress == cluster.selfUniqueAddress ⇒
      logInfo("Self removed, stopping ClusterSingletonManager")
      stop()
+    case Event(_: OldestChanged, _) ⇒
+      // not interested anymore - waiting for removal
+      stay
  }

  def selfMemberExited(): Unit = {