You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2026/03/22 09:45:46 UTC
(pekko) branch main updated: Use ClusterShuttingDown in ddata Replicator (#2765)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 98ed377601 Use ClusterShuttingDown in ddata Replicator (#2765)
98ed377601 is described below
commit 98ed377601cb845ba448a14a699410ee466baae3
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Sun Mar 22 10:45:39 2026 +0100
Use ClusterShuttingDown in ddata Replicator (#2765)
---
.../main/scala/org/apache/pekko/cluster/ddata/Replicator.scala | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
diff --git a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
index 2721108a36..8c876ad785 100644
--- a/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
+++ b/distributed-data/src/main/scala/org/apache/pekko/cluster/ddata/Replicator.scala
@@ -1453,7 +1453,12 @@ final class Replicator(settings: ReplicatorSettings) extends Actor with ActorLog
if (hasDurableKeys)
durableStore ! LoadAll
// not using LeaderChanged/RoleLeaderChanged because here we need one node independent of data center
- cluster.subscribe(self, initialStateMode = InitialStateAsEvents, classOf[MemberEvent], classOf[ReachabilityEvent])
+ cluster.subscribe(
+ self,
+ initialStateMode = InitialStateAsEvents,
+ classOf[MemberEvent],
+ ClusterShuttingDown.getClass,
+ classOf[ReachabilityEvent])
}
override def postStop(): Unit = {
@@ -1595,6 +1600,7 @@ final class Replicator(settings: ReplicatorSettings) extends Actor with ActorLog
case MemberUp(m) => receiveMemberUp(m)
case MemberExited(m) => receiveMemberExiting(m)
case MemberRemoved(m, _) => receiveMemberRemoved(m)
+ case ClusterShuttingDown => receiveMemberRemoved(cluster.selfMember)
case evt: MemberEvent => receiveOtherMemberEvent(evt.member)
case UnreachableMember(m) => receiveUnreachable(m)
case ReachableMember(m) => receiveReachable(m)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org