RestartShard handled on Shard (#3509)

akkadotnet · Jun 14, 2018 · fff8ae4 · fff8ae4
1 parent 5cf4ea6
commit fff8ae4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs b/src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs
@@ -450,6 +450,8 @@ internal static class Shards
                 case Shard.IShardQuery sq:
                     shard.HandleShardRegionQuery(sq);
                     return true;
+                case ShardRegion.RestartShard _:
+                    return true;
                 case var _ when shard.ExtractEntityId(message) != null:
                     shard.DeliverMessage(message, shard.Context.Sender);
                     return true;