diff --git a/akka-actor-tests/src/test/scala/akka/actor/SchedulerSpec.scala b/akka-actor-tests/src/test/scala/akka/actor/SchedulerSpec.scala index 0008c14e25..12db769b61 100644 --- a/akka-actor-tests/src/test/scala/akka/actor/SchedulerSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/actor/SchedulerSpec.scala @@ -10,7 +10,7 @@ import java.util.concurrent._ import atomic.{ AtomicReference, AtomicInteger } import scala.concurrent.{ future, Await, ExecutionContext } import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.util.Try import scala.util.control.NonFatal import org.scalatest.BeforeAndAfterEach diff --git a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerStressSpec.scala b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerStressSpec.scala index df14553347..e56f872c18 100644 --- a/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerStressSpec.scala +++ b/akka-actor-tests/src/test/scala/akka/pattern/CircuitBreakerStressSpec.scala @@ -5,7 +5,7 @@ package akka.pattern import scala.concurrent.Promise import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.Actor import akka.actor.ActorLogging import akka.actor.Props diff --git a/akka-actor/src/main/scala/akka/actor/ActorCell.scala b/akka-actor/src/main/scala/akka/actor/ActorCell.scala index 117ee5ef3d..21b6fc4d82 100644 --- a/akka-actor/src/main/scala/akka/actor/ActorCell.scala +++ b/akka-actor/src/main/scala/akka/actor/ActorCell.scala @@ -14,7 +14,7 @@ import scala.annotation.{ switch, tailrec } import scala.collection.immutable import scala.concurrent.ExecutionContextExecutor import scala.concurrent.duration.Duration -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.util.control.NonFatal import akka.dispatch.MessageDispatcher diff --git a/akka-actor/src/main/scala/akka/pattern/BackoffSupervisor.scala b/akka-actor/src/main/scala/akka/pattern/BackoffSupervisor.scala index 90b17ea725..705b7afd25 100644 --- a/akka-actor/src/main/scala/akka/pattern/BackoffSupervisor.scala +++ b/akka-actor/src/main/scala/akka/pattern/BackoffSupervisor.scala @@ -4,7 +4,7 @@ package akka.pattern import scala.concurrent.duration.FiniteDuration -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.Actor import akka.actor.ActorRef import akka.actor.DeadLetterSuppression diff --git a/akka-actor/src/main/scala/akka/routing/Random.scala b/akka-actor/src/main/scala/akka/routing/Random.scala index 6123a41f61..9a7e283aec 100644 --- a/akka-actor/src/main/scala/akka/routing/Random.scala +++ b/akka-actor/src/main/scala/akka/routing/Random.scala @@ -4,7 +4,7 @@ package akka.routing import scala.collection.immutable -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.ActorContext import akka.actor.Props import akka.dispatch.Dispatchers diff --git a/akka-actor/src/main/scala/akka/routing/SmallestMailbox.scala b/akka-actor/src/main/scala/akka/routing/SmallestMailbox.scala index 0ad4849815..86cca9aa24 100644 --- a/akka-actor/src/main/scala/akka/routing/SmallestMailbox.scala +++ b/akka-actor/src/main/scala/akka/routing/SmallestMailbox.scala @@ -5,7 +5,7 @@ package akka.routing import scala.annotation.tailrec import scala.collection.immutable -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import com.typesafe.config.Config import akka.actor.ActorCell import akka.actor.ActorRefWithCell diff --git a/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala b/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala index a2fc73e04c..2ed4fdab14 100644 --- a/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala +++ b/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsCollector.scala @@ -13,7 +13,7 @@ import akka.cluster.Member import akka.cluster.Cluster import scala.collection.immutable import akka.cluster.MemberStatus -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.Terminated import akka.actor.DeadLetterSuppression diff --git a/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsRouting.scala b/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsRouting.scala index 7b8862c8c9..9cb780cb98 100644 --- a/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsRouting.scala +++ b/akka-cluster-metrics/src/main/scala/akka/cluster/metrics/ClusterMetricsRouting.scala @@ -7,7 +7,7 @@ import java.util.Arrays import java.util.concurrent.atomic.AtomicReference import scala.annotation.tailrec import scala.collection.immutable -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import com.typesafe.config.Config import akka.actor.Actor import akka.actor.ActorSystem diff --git a/akka-cluster-metrics/src/test/scala/akka/cluster/metrics/EWMASpec.scala b/akka-cluster-metrics/src/test/scala/akka/cluster/metrics/EWMASpec.scala index 6685a7e466..f85876a2b0 100644 --- a/akka-cluster-metrics/src/test/scala/akka/cluster/metrics/EWMASpec.scala +++ b/akka-cluster-metrics/src/test/scala/akka/cluster/metrics/EWMASpec.scala @@ -7,7 +7,7 @@ package akka.cluster.metrics import language.postfixOps import scala.concurrent.duration._ import akka.testkit.{ LongRunningTest, AkkaSpec } -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom @org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner]) class EWMASpec extends AkkaSpec(MetricsConfig.defaultEnabled) with MetricsCollectorFactory { diff --git a/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala b/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala index d2604e4102..563791cb40 100644 --- a/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala +++ b/akka-cluster-tools/src/main/scala/akka/cluster/pubsub/DistributedPubSubMediator.scala @@ -7,7 +7,7 @@ package akka.cluster.pubsub import scala.collection.immutable import scala.collection.immutable.Set import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import java.net.URLEncoder import java.net.URLDecoder import akka.actor.Actor diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala index 7a09543853..f7a37357f8 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala @@ -7,7 +7,7 @@ import language.existentials import language.postfixOps import scala.collection.immutable import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.util.control.NonFatal import akka.actor._ import akka.actor.SupervisorStrategy.Stop diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala index bf68babb9a..f21998fb1d 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterMetricsCollector.scala @@ -13,7 +13,7 @@ import java.lang.reflect.InvocationTargetException import java.lang.reflect.Method import scala.collection.immutable import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.util.{ Try, Success, Failure } import akka.ConfigurationException import akka.actor.Actor diff --git a/akka-cluster/src/main/scala/akka/cluster/routing/AdaptiveLoadBalancing.scala b/akka-cluster/src/main/scala/akka/cluster/routing/AdaptiveLoadBalancing.scala index ba6af4c27e..ffed9df126 100644 --- a/akka-cluster/src/main/scala/akka/cluster/routing/AdaptiveLoadBalancing.scala +++ b/akka-cluster/src/main/scala/akka/cluster/routing/AdaptiveLoadBalancing.scala @@ -10,7 +10,7 @@ import java.util.concurrent.atomic.AtomicReference import scala.annotation.tailrec import scala.collection.immutable -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import com.typesafe.config.Config diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala index 0de47bb541..60a3d32d61 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/StressSpec.scala @@ -10,7 +10,7 @@ import language.postfixOps import scala.annotation.tailrec import scala.collection.immutable import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import java.util.concurrent.atomic.AtomicReference import org.scalatest.BeforeAndAfterEach import com.typesafe.config.Config diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala index c43138112b..a7d93f35e8 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/SurviveNetworkInstabilitySpec.scala @@ -10,7 +10,7 @@ import akka.remote.transport.ThrottlerTransportAdapter.Direction import scala.concurrent.duration._ import akka.testkit._ import akka.testkit.TestEvent._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.remote.testconductor.RoleName import akka.actor.Props import akka.actor.Actor diff --git a/akka-cluster/src/test/scala/akka/cluster/ClusterHeartbeatSenderStateSpec.scala b/akka-cluster/src/test/scala/akka/cluster/ClusterHeartbeatSenderStateSpec.scala index 605de99336..e220eb756b 100644 --- a/akka-cluster/src/test/scala/akka/cluster/ClusterHeartbeatSenderStateSpec.scala +++ b/akka-cluster/src/test/scala/akka/cluster/ClusterHeartbeatSenderStateSpec.scala @@ -11,7 +11,7 @@ import scala.concurrent.duration._ import scala.collection.immutable import akka.remote.FailureDetector import akka.remote.DefaultFailureDetectorRegistry -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom object ClusterHeartbeatSenderStateSpec { class FailureDetectorStub extends FailureDetector { diff --git a/akka-cluster/src/test/scala/akka/cluster/EWMASpec.scala b/akka-cluster/src/test/scala/akka/cluster/EWMASpec.scala index 16536ec5ff..002759d47d 100644 --- a/akka-cluster/src/test/scala/akka/cluster/EWMASpec.scala +++ b/akka-cluster/src/test/scala/akka/cluster/EWMASpec.scala @@ -9,7 +9,7 @@ package akka.cluster import language.postfixOps import scala.concurrent.duration._ import akka.testkit.{ LongRunningTest, AkkaSpec } -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom @org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner]) class EWMASpec extends AkkaSpec(MetricsEnabledSpec.config) with MetricsCollectorFactory { diff --git a/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala b/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala index ad359066f4..d285717c6d 100644 --- a/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala +++ b/akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala @@ -10,7 +10,7 @@ import scala.collection.immutable.Queue import scala.collection.mutable import scala.concurrent.duration._ import scala.concurrent.duration.FiniteDuration -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.util.Failure import scala.util.Success import scala.util.Try diff --git a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala index c66e88389d..54de6e2e27 100644 --- a/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala +++ b/akka-distributed-data/src/multi-jvm/scala/akka/cluster/ddata/JepsenInspiredInsertSpec.scala @@ -4,7 +4,7 @@ package akka.cluster.ddata import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.cluster.Cluster import akka.remote.testconductor.RoleName diff --git a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala index 4cbbafb0d5..83b0c9ed59 100644 --- a/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala +++ b/akka-distributed-data/src/test/scala/akka/cluster/ddata/LotsOfDataBot.scala @@ -4,7 +4,7 @@ package akka.cluster.ddata import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.Actor import akka.actor.ActorLogging import akka.actor.ActorSystem diff --git a/akka-docs/rst/java/code/docs/ddata/DataBot.java b/akka-docs/rst/java/code/docs/ddata/DataBot.java index 8802063db6..ec2388e020 100644 --- a/akka-docs/rst/java/code/docs/ddata/DataBot.java +++ b/akka-docs/rst/java/code/docs/ddata/DataBot.java @@ -6,7 +6,7 @@ package docs.ddata; //#data-bot import static java.util.concurrent.TimeUnit.SECONDS; import scala.concurrent.duration.Duration; -import scala.concurrent.forkjoin.ThreadLocalRandom; +import java.util.concurrent.ThreadLocalRandom; import akka.actor.AbstractActor; import akka.actor.ActorRef; diff --git a/akka-docs/rst/java/code/docs/ddata/DistributedDataDocTest.java b/akka-docs/rst/java/code/docs/ddata/DistributedDataDocTest.java index ac70471ee6..dd07bcdafc 100644 --- a/akka-docs/rst/java/code/docs/ddata/DistributedDataDocTest.java +++ b/akka-docs/rst/java/code/docs/ddata/DistributedDataDocTest.java @@ -18,7 +18,7 @@ import org.junit.Test; import org.junit.AfterClass; import org.junit.BeforeClass; import scala.concurrent.duration.FiniteDuration; -import scala.concurrent.forkjoin.ThreadLocalRandom; +import java.util.concurrent.ThreadLocalRandom; import akka.actor.Actor; import akka.actor.ActorLogging; diff --git a/akka-docs/rst/scala/code/docs/ddata/DistributedDataDocSpec.scala b/akka-docs/rst/scala/code/docs/ddata/DistributedDataDocSpec.scala index 8a450c0615..fdf37090e0 100644 --- a/akka-docs/rst/scala/code/docs/ddata/DistributedDataDocSpec.scala +++ b/akka-docs/rst/scala/code/docs/ddata/DistributedDataDocSpec.scala @@ -4,7 +4,7 @@ package docs.ddata import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.Actor import akka.actor.ActorLogging import akka.cluster.Cluster @@ -47,7 +47,7 @@ object DistributedDataDocSpec { """ //#data-bot - import scala.concurrent.forkjoin.ThreadLocalRandom + import java.util.concurrent.ThreadLocalRandom import akka.actor.Actor import akka.actor.ActorLogging import akka.cluster.Cluster diff --git a/akka-docs/rst/scala/code/docs/routing/CustomRouterDocSpec.scala b/akka-docs/rst/scala/code/docs/routing/CustomRouterDocSpec.scala index d73da598da..271fe26169 100644 --- a/akka-docs/rst/scala/code/docs/routing/CustomRouterDocSpec.scala +++ b/akka-docs/rst/scala/code/docs/routing/CustomRouterDocSpec.scala @@ -41,7 +41,7 @@ akka.actor.deployment { //#routing-logic import scala.collection.immutable - import scala.concurrent.forkjoin.ThreadLocalRandom + import java.util.concurrent.ThreadLocalRandom import akka.routing.RoundRobinRoutingLogic import akka.routing.RoutingLogic import akka.routing.Routee diff --git a/akka-persistence/src/test/scala/akka/persistence/AtLeastOnceDeliveryFailureSpec.scala b/akka-persistence/src/test/scala/akka/persistence/AtLeastOnceDeliveryFailureSpec.scala index e614556fe4..668e7a1a0a 100644 --- a/akka-persistence/src/test/scala/akka/persistence/AtLeastOnceDeliveryFailureSpec.scala +++ b/akka-persistence/src/test/scala/akka/persistence/AtLeastOnceDeliveryFailureSpec.scala @@ -5,7 +5,7 @@ package akka.persistence import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.language.postfixOps import com.typesafe.config.ConfigFactory diff --git a/akka-persistence/src/test/scala/akka/persistence/journal/chaos/ChaosJournal.scala b/akka-persistence/src/test/scala/akka/persistence/journal/chaos/ChaosJournal.scala index 848cbc2073..5a28a3b1d7 100644 --- a/akka-persistence/src/test/scala/akka/persistence/journal/chaos/ChaosJournal.scala +++ b/akka-persistence/src/test/scala/akka/persistence/journal/chaos/ChaosJournal.scala @@ -6,7 +6,7 @@ package akka.persistence.journal.chaos import scala.collection.immutable import scala.concurrent.Future -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.persistence._ import akka.persistence.journal.AsyncWriteJournal import akka.persistence.journal.inmem.InmemMessages diff --git a/akka-remote/src/main/scala/akka/remote/AddressUidExtension.scala b/akka-remote/src/main/scala/akka/remote/AddressUidExtension.scala index 1fa28cab60..b175380ad1 100644 --- a/akka-remote/src/main/scala/akka/remote/AddressUidExtension.scala +++ b/akka-remote/src/main/scala/akka/remote/AddressUidExtension.scala @@ -3,7 +3,7 @@ */ package akka.remote -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.actor.ActorSystem import akka.actor.ExtendedActorSystem import akka.actor.Extension diff --git a/akka-remote/src/main/scala/akka/remote/transport/FailureInjectorTransportAdapter.scala b/akka-remote/src/main/scala/akka/remote/transport/FailureInjectorTransportAdapter.scala index 341f55a85e..6eb918f9ad 100644 --- a/akka-remote/src/main/scala/akka/remote/transport/FailureInjectorTransportAdapter.scala +++ b/akka-remote/src/main/scala/akka/remote/transport/FailureInjectorTransportAdapter.scala @@ -11,7 +11,7 @@ import akka.remote.transport.AssociationHandle.{ HandleEvent, HandleEventListene import akka.remote.transport.Transport._ import akka.util.ByteString import java.util.concurrent.ConcurrentHashMap -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import scala.concurrent.{ Future, Promise } import scala.util.control.NoStackTrace import scala.util.Try diff --git a/akka-remote/src/test/scala/akka/remote/AckedDeliverySpec.scala b/akka-remote/src/test/scala/akka/remote/AckedDeliverySpec.scala index ec69410b6c..116f4a2b24 100644 --- a/akka-remote/src/test/scala/akka/remote/AckedDeliverySpec.scala +++ b/akka-remote/src/test/scala/akka/remote/AckedDeliverySpec.scala @@ -5,7 +5,7 @@ package akka.remote import akka.testkit.AkkaSpec import scala.annotation.tailrec -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom object AckedDeliverySpec { diff --git a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala index d0fd090cf3..8eeb9d803e 100644 --- a/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala +++ b/akka-remote/src/test/scala/akka/remote/RemotingSpec.scala @@ -16,7 +16,7 @@ import java.io.NotSerializableException import scala.concurrent.Await import scala.concurrent.Future import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import akka.testkit.SocketUtil.temporaryServerAddress object RemotingSpec { diff --git a/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/stats/StatsSampleClient.java b/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/stats/StatsSampleClient.java index 8c4a30ca24..73883382d5 100644 --- a/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/stats/StatsSampleClient.java +++ b/akka-samples/akka-sample-cluster-java/src/main/java/sample/cluster/stats/StatsSampleClient.java @@ -9,7 +9,7 @@ import java.util.concurrent.TimeUnit; import sample.cluster.stats.StatsMessages.JobFailed; import sample.cluster.stats.StatsMessages.StatsJob; import sample.cluster.stats.StatsMessages.StatsResult; -import scala.concurrent.forkjoin.ThreadLocalRandom; +import java.util.concurrent.ThreadLocalRandom; import scala.concurrent.duration.Duration; import scala.concurrent.duration.FiniteDuration; import akka.actor.ActorSelection; diff --git a/akka-samples/akka-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsSample.scala b/akka-samples/akka-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsSample.scala index 060de44d0c..b32dd961a8 100644 --- a/akka-samples/akka-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsSample.scala +++ b/akka-samples/akka-sample-cluster-scala/src/main/scala/sample/cluster/stats/StatsSample.scala @@ -1,7 +1,7 @@ package sample.cluster.stats import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import com.typesafe.config.ConfigFactory import akka.actor.Actor import akka.actor.ActorSystem diff --git a/akka-samples/akka-sample-fsm-scala/src/main/scala/sample/redelivery/FsmSimpleRedelivery.scala b/akka-samples/akka-sample-fsm-scala/src/main/scala/sample/redelivery/FsmSimpleRedelivery.scala index 0f8c4208d9..406d7d9057 100644 --- a/akka-samples/akka-sample-fsm-scala/src/main/scala/sample/redelivery/FsmSimpleRedelivery.scala +++ b/akka-samples/akka-sample-fsm-scala/src/main/scala/sample/redelivery/FsmSimpleRedelivery.scala @@ -6,7 +6,7 @@ package sample.redelivery import akka.actor._ import scala.concurrent.duration._ -import scala.concurrent.forkjoin.ThreadLocalRandom +import java.util.concurrent.ThreadLocalRandom import java.util.UUID object SimpleOrderedRedeliverer {