some compile issues

apache · Jan 30, 2025 · bf76e89 · bf76e89
1 parent 1e345b0
commit bf76e89
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/...ed/src/main/scala/org/apache/pekko/actor/testkit/typed/internal/StubbedActorContext.scala b/...ed/src/main/scala/org/apache/pekko/actor/testkit/typed/internal/StubbedActorContext.scala
@@ -173,7 +173,7 @@ private[pekko] final class FunctionRef[-T](override val path: ActorPath, send: (
   @InternalApi private[pekko] def internalSpawnMessageAdapter[U](f: U => T, name: String): ActorRef[U] = {
 
     val n = if (name != "") s"${childName.next()}-$name" else childName.next()
-    val p = (path / n).withUid(rnd().nextInt())
+    val p = (path / n).withUid(RandomNumberGenerator.get().nextInt())
     val i = new BehaviorTestKitImpl[U](system, p, BehaviorImpl.ignore)
     _children += p.name -> i
 

diff --git a/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreaker.scala b/actor/src/main/scala/org/apache/pekko/pattern/CircuitBreaker.scala
@@ -14,7 +14,7 @@
 package org.apache.pekko.pattern
 
 import java.util.Optional
-import java.util.concurrent.{ Callable, CompletionException, CompletionStage, CopyOnWriteArrayList, ThreadLocalRandom }
+import java.util.concurrent.{ Callable, CompletionException, CompletionStage, CopyOnWriteArrayList }
 import java.util.concurrent.atomic.{ AtomicBoolean, AtomicInteger, AtomicLong }
 import java.util.function.BiFunction
 import java.util.function.Consumer
@@ -32,7 +32,7 @@ import pekko.dispatch.ExecutionContexts.parasitic
 import pekko.pattern.internal.{ CircuitBreakerNoopTelemetry, CircuitBreakerTelemetry }
 import pekko.util.FutureConverters._
 import pekko.util.JavaDurationConverters._
-import pekko.util.Unsafe
+import pekko.util.{ RandomNumberGenerator, Unsafe }
 
 /**
  * Companion object providing factory methods for Circuit Breaker which runs callbacks in caller's thread

diff --git a/actor/src/main/scala/org/apache/pekko/util/RandomNumberGenerator.scala b/actor/src/main/scala/org/apache/pekko/util/RandomNumberGenerator.scala
@@ -26,6 +26,7 @@ import java.util.concurrent.ThreadLocalRandom
 private[pekko] trait RandomNumberGenerator {
   def nextInt(): Int
   def nextInt(n: Int): Int
+  def nextInt(origin: Int, n: Int): Int
   def nextLong(): Long
   def nextDouble(): Double
 }
@@ -34,6 +35,7 @@ private[pekko] trait RandomNumberGenerator {
 private[pekko] object ThreadLocalRandomNumberGenerator extends RandomNumberGenerator {
   override def nextInt(): Int = ThreadLocalRandom.current().nextInt()
   override def nextInt(bound: Int): Int = ThreadLocalRandom.current().nextInt(bound)
+  override def nextInt(origin: Int, bound: Int): Int = ThreadLocalRandom.current().nextInt(origin, bound)
   override def nextLong(): Long = ThreadLocalRandom.current().nextLong()
   override def nextDouble(): Double = ThreadLocalRandom.current().nextDouble()
 }