From 9c7f16a4dbfa29fb873b59be856e295dba91382a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Johan=20Andr=C3=A9n?= <johan@markatta.com>
Date: Thu, 11 Jun 2020 15:46:03 +0200
Subject: [PATCH] Re-use logic for allocating shard home for remembered
 entities

---
 .../src/main/scala/akka/cluster/sharding/ShardCoordinator.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
index c724cb2a93..eefea65243 100644
--- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
+++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala
@@ -1422,7 +1422,7 @@ private[akka] class DDataShardCoordinator(
       if (shardIds.nonEmpty) {
         val newUnallocatedShards = state.unallocatedShards.union(shardIds.diff(state.shards.keySet))
         state = state.copy(unallocatedShards = newUnallocatedShards)
-        newUnallocatedShards.foreach { self ! GetShardHome(_) }
+        allocateShardHomesForRememberEntities()
       }
       timers.cancel(RememberEntitiesTimeoutKey)