diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs index 1b39526b6cf..01f7b95fa15 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs @@ -1792,7 +1792,7 @@ internal bool Active(object message) case ResendShardHost m: { - if (State.Shards.TryGetValue(m.Shard, out var region) && region.Equals(region)) + if (State.Shards.TryGetValue(m.Shard, out var region) && region.Equals(m.Region)) SendHostShardMsg(m.Shard, region); else {