diff --git a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala index 9c62b648ad..6eff811961 100644 --- a/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala +++ b/akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala @@ -108,7 +108,7 @@ private[akka] final class ShardedDaemonProcessImpl(system: ActorSystem[_]) // One shard per actor identified by the numeric id encoded in the entity id val numberOfShards = numberOfInstances - val entityIds = (0 to numberOfInstances).map(_.toString) + val entityIds = (0 until numberOfInstances).map(_.toString) val shardingSettings = { val shardingBaseSettings = diff --git a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala index e06b610ae0..1f2cab6108 100644 --- a/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala +++ b/akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala @@ -79,6 +79,7 @@ class ShardedDaemonProcessSpec val started = probe.receiveMessages(5) started.toSet.size should ===(5) + probe.expectNoMessage() } "restart actors if they stop" in {