diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs index 869bb4b10b3..e45f4dbfc4b 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs @@ -541,12 +541,12 @@ private bool ReceiveLateRememberedEntities(object message) _baseImpl.AllocateShardHomesForRememberEntities(); } Timers.Cancel(RememberEntitiesTimeoutKey); - break; + return true; case RememberEntitiesLoadTimeout _: // repeat until successful GetAllRememberedShards(); - break; + return true; } return false; }