From f8c589221c3a3381534d17426ca423720c9ce4e9 Mon Sep 17 00:00:00 2001 From: zbynek001 Date: Mon, 13 Nov 2017 01:02:42 +0100 Subject: [PATCH] RegionProxyTerminated fix --- .../cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs | 2 +- src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs index 531a9c55029..2789bf5f100 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/PersistentShardCoordinator.cs @@ -473,7 +473,7 @@ private void WatchStateActors() if (a.HasLocalScope || nodes.Contains(a)) Context.Watch(proxy); else - RegionTerminated(proxy); // not part of the cluster + RegionProxyTerminated(proxy); // not part of the cluster } // Let the quick (those not involving failure detection) Terminated messages diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs index 68ff5865529..c48ce3b06f1 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs @@ -807,7 +807,7 @@ private void HandleCoordinatorMessage(PersistentShardCoordinator.ICoordinatorMes updatedShards = updatedShards.Remove(shard); Regions = updatedShards.Count == 0 - ? Regions = Regions.Remove(regionRef) + ? Regions.Remove(regionRef) : Regions.SetItem(regionRef, updatedShards); RegionByShard = RegionByShard.Remove(shard);