Update ReplicatedShardingTest.java

apache · Jan 30, 2025 · e4fda5f · e4fda5f
1 parent bf76e89
commit e4fda5f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...g-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingTest.java b/...g-typed/src/test/java/org/apache/pekko/cluster/sharding/typed/ReplicatedShardingTest.java
@@ -201,7 +201,7 @@ public Receive<Command> createReceive() {
     private Behavior<Command> onForwardToRandom(ForwardToRandom forwardToRandom) {
       Map<ReplicaId, EntityRef<MyReplicatedStringSet.Command>> refs =
           replicatedSharding.getEntityRefsFor(forwardToRandom.entityId);
-      int chosenIdx = RandomNumberGenerator.get().nextInt(refs.size());
+      int chosenIdx = ThreadLocalRandom.current().nextInt(refs.size());
       new ArrayList<>(refs.values()).get(chosenIdx).tell(forwardToRandom.message);
       return this;
     }