From e866e3fc70638ee2fbcc7383dc3182aea09afd4b Mon Sep 17 00:00:00 2001 From: Nicolas Vollmar Date: Tue, 23 Apr 2019 11:20:42 +0200 Subject: [PATCH] Discards HandOverToMe in state End to avoid unhandled message warning #26793 --- .../akka/cluster/singleton/ClusterSingletonManager.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala b/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala index e2ab797e22..859a598e9b 100644 --- a/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala +++ b/akka-cluster-tools/src/main/scala/akka/cluster/singleton/ClusterSingletonManager.scala @@ -981,9 +981,9 @@ class ClusterSingletonManager(singletonProps: Props, terminationMessage: Any, se case Event(MemberRemoved(m, _), _) if m.uniqueAddress == cluster.selfUniqueAddress => logInfo("Self removed, stopping ClusterSingletonManager") stop() - case Event(_: OldestChanged, _) => + case Event(_: OldestChanged | HandOverToMe, _) => // not interested anymore - waiting for removal - stay + stay() } def selfMemberExited(): Unit = {