Fix unhandled RememberShards by DDataShardCoordinator (#6160)

akkadotnet · Oct 8, 2022 · bf543ff · bf543ff
1 parent 6259295
commit bf543ff
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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;
         }