raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

ShardedDaemonSet creates one too many (#28766)

Browse source
This commit is contained in:
Christopher Batey 2020-03-19 11:58:58 +00:00 • committed by GitHub
parent bcfdb896b0
commit 992e3624bb
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-cluster-sharding-typed/src/main/scala/akka/cluster/sharding/typed/internal/ShardedDaemonProcessImpl.scala
View file

@ -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 // One shard per actor identified by the numeric id encoded in the entity id
val numberOfShards = numberOfInstances val numberOfShards = numberOfInstances
val entityIds = (0 to numberOfInstances).map(_.toString) val entityIds = (0 until numberOfInstances).map(_.toString)
val shardingSettings = { val shardingSettings = {
val shardingBaseSettings = val shardingBaseSettings =

1
akka-cluster-sharding-typed/src/test/scala/akka/cluster/sharding/typed/scaladsl/ShardedDaemonProcessSpec.scala
View file

@ -79,6 +79,7 @@ class ShardedDaemonProcessSpec
val started = probe.receiveMessages(5) val started = probe.receiveMessages(5)
started.toSet.size should ===(5) started.toSet.size should ===(5)
probe.expectNoMessage()
} }
"restart actors if they stop" in { "restart actors if they stop" in {