From aa874d610f95ef8b801da8dc808b995eb2af6e79 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Thu, 11 Jun 2020 16:58:41 +0200 Subject: [PATCH] Require set of remembered entities to start to be nonEmpty --- .../akka/cluster/sharding/internal/RememberEntityStarter.scala | 2 ++ 1 file changed, 2 insertions(+) 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]