diff --git a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/RememberEntityStarter.scala b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/RememberEntityStarter.scala index f17749fffe..e66c95cde2 100644 --- a/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/RememberEntityStarter.scala +++ b/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/internal/RememberEntityStarter.scala @@ -54,6 +54,8 @@ private[akka] final class RememberEntityStarter( implicit val ec: ExecutionContext = context.dispatcher import RememberEntityStarter._ + require(ids.nonEmpty) + private var idsLeftToStart = Set.empty[EntityId] private var waitingForAck = Set.empty[EntityId] private var entitiesMoved = Set.empty[EntityId]