Rename classes containing Akka to Pekko
This commit is contained in:
Matthew de Detrich
Matthew de Detrich
parent
3d93dbcb81
commit
0cb5056ad5
584 changed files with 1950 additions and 1947 deletions
|
|
@ -24,7 +24,7 @@ import pekko.annotation.InternalApi
|
|||
@InternalApi private[pekko] object TestAppender {
|
||||
import LogbackUtil._
|
||||
|
||||
private val TestAppenderName = "AkkaTestAppender"
|
||||
private val TestAppenderName = "PekkoTestAppender"
|
||||
|
||||
def setupTestAppender(loggerName: String): Unit = {
|
||||
val logbackLogger = getLogbackLogger(loggerName)
|
||||
|
|
|
|||
|
|
@ -4,8 +4,8 @@
|
|||
|
||||
package org.apache.pekko.actor;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import org.apache.pekko.testkit.TestProbe;
|
||||
import org.junit.ClassRule;
|
||||
import org.junit.Test;
|
||||
|
|
@ -34,8 +34,8 @@ public class AbstractFSMActorTest extends JUnitSuite {
|
|||
}
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("AbstractFSMActorTest", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("AbstractFSMActorTest", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -8,8 +8,8 @@ import java.time.Duration;
|
|||
import java.util.concurrent.CompletionStage;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
|
||||
import org.junit.ClassRule;
|
||||
import org.junit.Test;
|
||||
|
|
@ -20,8 +20,8 @@ import static org.junit.Assert.assertEquals;
|
|||
public class ActorSelectionTest extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("ActorSelectionTest", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("ActorSelectionTest", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@
|
|||
|
||||
package org.apache.pekko.actor;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.junit.Before;
|
||||
import org.junit.Rule;
|
||||
import org.junit.Test;
|
||||
|
|
@ -18,8 +18,8 @@ import static org.junit.Assert.assertFalse;
|
|||
public class ActorSystemTest extends JUnitSuite {
|
||||
|
||||
@Rule
|
||||
public final AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("ActorSystemTest");
|
||||
public final PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("ActorSystemTest");
|
||||
|
||||
private ActorSystem system = null;
|
||||
|
||||
|
|
|
|||
|
|
@ -14,8 +14,8 @@ import org.apache.pekko.japi.tuple.Tuple4;
|
|||
import org.apache.pekko.routing.GetRoutees;
|
||||
import org.apache.pekko.routing.FromConfig;
|
||||
import org.apache.pekko.routing.NoRouter;
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import org.apache.pekko.testkit.TestProbe;
|
||||
|
||||
import org.junit.ClassRule;
|
||||
|
|
@ -30,8 +30,8 @@ import static org.junit.Assert.*;
|
|||
public class JavaAPI extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("JavaAPI", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("JavaAPI", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -4,9 +4,9 @@
|
|||
|
||||
package org.apache.pekko.actor;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.junit.*;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import com.typesafe.config.ConfigFactory;
|
||||
import org.scalatestplus.junit.JUnitSuite;
|
||||
|
||||
|
|
@ -62,12 +62,12 @@ public class JavaExtension extends JUnitSuite {
|
|||
}
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource(
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource(
|
||||
"JavaExtension",
|
||||
ConfigFactory.parseString(
|
||||
"pekko.extensions = [ \"org.apache.pekko.actor.JavaExtension$TestExtensionId\" ]")
|
||||
.withFallback(AkkaSpec.testConf()));
|
||||
.withFallback(PekkoSpec.testConf()));
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@
|
|||
|
||||
package org.apache.pekko.actor;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.TestProbe;
|
||||
|
||||
import org.junit.ClassRule;
|
||||
|
|
@ -14,8 +14,8 @@ import org.scalatestplus.junit.JUnitSuite;
|
|||
public class StashJavaAPI extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("StashJavaAPI", ActorWithBoundedStashSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("StashJavaAPI", ActorWithBoundedStashSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -4,7 +4,7 @@
|
|||
|
||||
package org.apache.pekko.dispatch;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.actor.ActorSystem;
|
||||
|
||||
import org.apache.pekko.japi.*;
|
||||
|
|
@ -25,13 +25,13 @@ import java.util.concurrent.CountDownLatch;
|
|||
import java.util.concurrent.TimeUnit;
|
||||
import static org.apache.pekko.japi.Util.classTag;
|
||||
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
|
||||
public class JavaFutureTests extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("JavaFutureTests", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("JavaFutureTests", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
private final Duration timeout = Duration.create(5, TimeUnit.SECONDS);
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@ package org.apache.pekko.event;
|
|||
import org.apache.pekko.actor.ActorRef;
|
||||
import org.apache.pekko.actor.ActorSystem;
|
||||
import org.apache.pekko.actor.Props;
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.event.Logging.Error;
|
||||
import org.apache.pekko.event.ActorWithMDC.Log;
|
||||
import static org.apache.pekko.event.Logging.*;
|
||||
|
|
@ -33,8 +33,8 @@ public class LoggingAdapterTest extends JUnitSuite {
|
|||
private static final Config config = ConfigFactory.parseString("pekko.loglevel = DEBUG\n");
|
||||
|
||||
@Rule
|
||||
public AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("LoggingAdapterTest", config);
|
||||
public PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("LoggingAdapterTest", config);
|
||||
|
||||
private ActorSystem system = null;
|
||||
|
||||
|
|
|
|||
|
|
@ -5,8 +5,8 @@
|
|||
package org.apache.pekko.pattern;
|
||||
|
||||
import org.apache.pekko.actor.*;
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import org.apache.pekko.util.JavaDurationConverters;
|
||||
import org.junit.ClassRule;
|
||||
import org.junit.Test;
|
||||
|
|
@ -25,8 +25,8 @@ import static org.junit.Assert.assertEquals;
|
|||
public class CircuitBreakerTest extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("JavaAPI", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("JavaAPI", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -6,8 +6,8 @@ package org.apache.pekko.pattern;
|
|||
|
||||
import org.apache.pekko.actor.*;
|
||||
import org.apache.pekko.dispatch.Futures;
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import org.apache.pekko.testkit.TestProbe;
|
||||
import org.apache.pekko.util.Timeout;
|
||||
import org.junit.ClassRule;
|
||||
|
|
@ -62,8 +62,8 @@ public class PatternsTest extends JUnitSuite {
|
|||
}
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("JavaAPI", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("JavaAPI", PekkoSpec.testConf());
|
||||
|
||||
private final ActorSystem system = actorSystemResource.getSystem();
|
||||
|
||||
|
|
|
|||
|
|
@ -5,8 +5,8 @@
|
|||
package org.apache.pekko.pattern;
|
||||
|
||||
import org.apache.pekko.actor.ActorRef;
|
||||
import org.apache.pekko.testkit.AkkaJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.AkkaSpec;
|
||||
import org.apache.pekko.testkit.PekkoJUnitActorSystemResource;
|
||||
import org.apache.pekko.testkit.PekkoSpec;
|
||||
import org.apache.pekko.testkit.TestException;
|
||||
import org.apache.pekko.testkit.TestProbe;
|
||||
import org.junit.Assert;
|
||||
|
|
@ -26,8 +26,8 @@ import static org.junit.Assert.*;
|
|||
public class StatusReplyTest extends JUnitSuite {
|
||||
|
||||
@ClassRule
|
||||
public static AkkaJUnitActorSystemResource actorSystemResource =
|
||||
new AkkaJUnitActorSystemResource("JavaAPI", AkkaSpec.testConf());
|
||||
public static PekkoJUnitActorSystemResource actorSystemResource =
|
||||
new PekkoJUnitActorSystemResource("JavaAPI", PekkoSpec.testConf());
|
||||
|
||||
@Test
|
||||
public void successReplyThrowsExceptionWhenGetErrorIsCalled() {
|
||||
|
|
|
|||
|
|
@ -5,10 +5,10 @@
|
|||
package org.apache.pekko.util
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.util.LineNumbers._
|
||||
|
||||
class LineNumberSpec extends AkkaSpec {
|
||||
class LineNumberSpec extends PekkoSpec {
|
||||
|
||||
"LineNumbers" when {
|
||||
|
||||
|
|
|
|||
|
|
@ -5,10 +5,10 @@
|
|||
package org.apache.pekko.util
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.util.LineNumbers._
|
||||
|
||||
class LineNumberSpec extends AkkaSpec {
|
||||
class LineNumberSpec extends PekkoSpec {
|
||||
|
||||
"LineNumbers" when {
|
||||
|
||||
|
|
|
|||
|
|
@ -5,10 +5,10 @@
|
|||
package org.apache.pekko.util
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.util.LineNumbers._
|
||||
|
||||
class LineNumberSpec extends AkkaSpec {
|
||||
class LineNumberSpec extends PekkoSpec {
|
||||
|
||||
"LineNumbers" when {
|
||||
|
||||
|
|
|
|||
|
|
@ -1,86 +0,0 @@
|
|||
/*
|
||||
* Copyright (C) 2009-2022 Lightbend Inc. <https://www.lightbend.com>
|
||||
*/
|
||||
|
||||
package org.apache.pekko
|
||||
|
||||
import org.scalatest.matchers.should.Matchers
|
||||
import org.scalatest.wordspec.AnyWordSpec
|
||||
|
||||
class AkkaVersionSpec extends AnyWordSpec with Matchers {
|
||||
|
||||
"The Akka version check" must {
|
||||
|
||||
"succeed if version is ok" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.6")
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.7")
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.6.0")
|
||||
}
|
||||
|
||||
"succeed if version is RC and ok" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.7-RC10")
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.6.0-RC1", "2.6.0-RC1")
|
||||
}
|
||||
|
||||
"fail if version is RC and not ok" in {
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.6-RC1")
|
||||
}
|
||||
}
|
||||
|
||||
"succeed if version is milestone and ok" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.7-M10")
|
||||
}
|
||||
|
||||
"fail if version is milestone and not ok" in {
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.6-M1")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if major version is different" in {
|
||||
// because not bincomp
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "3.0.0")
|
||||
}
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "1.0.0")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if minor version is too low" in {
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.4.19")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if patch version is too low" in {
|
||||
intercept[UnsupportedAkkaVersion] {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5.5")
|
||||
}
|
||||
}
|
||||
|
||||
"succeed if current Akka version is SNAPSHOT" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5-SNAPSHOT")
|
||||
}
|
||||
|
||||
"succeed if current Akka version is timestamped SNAPSHOT" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5.6", "2.5-20180109-133700")
|
||||
}
|
||||
|
||||
"succeed if required Akka version is SNAPSHOT" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5-SNAPSHOT", "2.5-SNAPSHOT")
|
||||
}
|
||||
|
||||
"succeed if required Akka version is timestamped SNAPSHOT" in {
|
||||
AkkaVersion.require("AkkaVersionSpec", "2.5-20180109-133700", "2.5-20180109-133700")
|
||||
}
|
||||
|
||||
"silently comply if current version is incomprehensible" in {
|
||||
// because we may want to release with weird numbers for some reason
|
||||
AkkaVersion.require("nonsense", "2.5.6", "nonsense")
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -10,17 +10,17 @@ import org.scalatest.wordspec.AnyWordSpec
|
|||
import org.apache.pekko.actor._
|
||||
|
||||
/**
|
||||
* A spec that verified that the AkkaException has at least a single argument constructor of type String.
|
||||
* A spec that verified that the PekkoException has at least a single argument constructor of type String.
|
||||
*
|
||||
* This is required to make Akka Exceptions be friends with serialization/deserialization.
|
||||
* This is required to make Pekko Exceptions be friends with serialization/deserialization.
|
||||
*/
|
||||
class AkkaExceptionSpec extends AnyWordSpec with Matchers {
|
||||
class PekkoExceptionSpec extends AnyWordSpec with Matchers {
|
||||
|
||||
"AkkaException" must {
|
||||
"have a AkkaException(String msg) constructor to be serialization friendly" in {
|
||||
"PekkoException" must {
|
||||
"have a PekkoException(String msg) constructor to be serialization friendly" in {
|
||||
// if the call to this method completes, we know what there is at least a single constructor which has
|
||||
// the expected argument type.
|
||||
verify(classOf[AkkaException])
|
||||
verify(classOf[PekkoException])
|
||||
|
||||
// lets also try it for the exception that triggered this bug to be discovered.
|
||||
verify(classOf[ActorKilledException])
|
||||
|
|
@ -0,0 +1,86 @@
|
|||
/*
|
||||
* Copyright (C) 2009-2022 Lightbend Inc. <https://www.lightbend.com>
|
||||
*/
|
||||
|
||||
package org.apache.pekko
|
||||
|
||||
import org.scalatest.matchers.should.Matchers
|
||||
import org.scalatest.wordspec.AnyWordSpec
|
||||
|
||||
class PekkoVersionSpec extends AnyWordSpec with Matchers {
|
||||
|
||||
"The Pekko version check" must {
|
||||
|
||||
"succeed if version is ok" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.6")
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.7")
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.6.0")
|
||||
}
|
||||
|
||||
"succeed if version is RC and ok" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.7-RC10")
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.6.0-RC1", "2.6.0-RC1")
|
||||
}
|
||||
|
||||
"fail if version is RC and not ok" in {
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.6-RC1")
|
||||
}
|
||||
}
|
||||
|
||||
"succeed if version is milestone and ok" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.7-M10")
|
||||
}
|
||||
|
||||
"fail if version is milestone and not ok" in {
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.6-M1")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if major version is different" in {
|
||||
// because not bincomp
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "3.0.0")
|
||||
}
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "1.0.0")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if minor version is too low" in {
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.4.19")
|
||||
}
|
||||
}
|
||||
|
||||
"fail if patch version is too low" in {
|
||||
intercept[UnsupportedPekkoVersion] {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5.5")
|
||||
}
|
||||
}
|
||||
|
||||
"succeed if current Pekko version is SNAPSHOT" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5-SNAPSHOT")
|
||||
}
|
||||
|
||||
"succeed if current Pekko version is timestamped SNAPSHOT" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5.6", "2.5-20180109-133700")
|
||||
}
|
||||
|
||||
"succeed if required Pekko version is SNAPSHOT" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5-SNAPSHOT", "2.5-SNAPSHOT")
|
||||
}
|
||||
|
||||
"succeed if required Pekko version is timestamped SNAPSHOT" in {
|
||||
PekkoVersion.require("PekkoVersionSpec", "2.5-20180109-133700", "2.5-20180109-133700")
|
||||
}
|
||||
|
||||
"silently comply if current version is incomprehensible" in {
|
||||
// because we may want to release with weird numbers for some reason
|
||||
PekkoVersion.require("nonsense", "2.5.6", "nonsense")
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
|
@ -37,7 +37,7 @@ object ActorConfigurationVerificationSpec {
|
|||
}
|
||||
|
||||
class ActorConfigurationVerificationSpec
|
||||
extends AkkaSpec(ActorConfigurationVerificationSpec.config)
|
||||
extends PekkoSpec(ActorConfigurationVerificationSpec.config)
|
||||
with DefaultTimeout
|
||||
with BeforeAndAfterEach {
|
||||
import ActorConfigurationVerificationSpec._
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ import com.typesafe.config.ConfigFactory
|
|||
import org.scalatest.BeforeAndAfterAll
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender, PerformanceTest }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec, PerformanceTest }
|
||||
import pekko.testkit.metrics._
|
||||
import pekko.testkit.metrics.HeapMemoryUsage
|
||||
|
||||
|
|
@ -118,7 +118,7 @@ object ActorCreationPerfSpec {
|
|||
}
|
||||
|
||||
class ActorCreationPerfSpec
|
||||
extends AkkaSpec(ActorCreationPerfSpec.config)
|
||||
extends PekkoSpec(ActorCreationPerfSpec.config)
|
||||
with ImplicitSender
|
||||
with MetricsKit
|
||||
with BeforeAndAfterAll {
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ object ActorLifeCycleSpec {
|
|||
|
||||
}
|
||||
|
||||
class ActorLifeCycleSpec extends AkkaSpec with BeforeAndAfterEach with ImplicitSender with DefaultTimeout {
|
||||
class ActorLifeCycleSpec extends PekkoSpec with BeforeAndAfterEach with ImplicitSender with DefaultTimeout {
|
||||
import ActorLifeCycleSpec._
|
||||
|
||||
"An Actor" must {
|
||||
|
|
|
|||
|
|
@ -226,7 +226,7 @@ object ActorMailboxSpec {
|
|||
|
||||
}
|
||||
|
||||
class ActorMailboxSpec(conf: Config) extends AkkaSpec(conf) with DefaultTimeout with ImplicitSender {
|
||||
class ActorMailboxSpec(conf: Config) extends PekkoSpec(conf) with DefaultTimeout with ImplicitSender {
|
||||
|
||||
import ActorMailboxSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -112,7 +112,7 @@ object ActorRefSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class ActorRefSpec extends AkkaSpec("""
|
||||
class ActorRefSpec extends PekkoSpec("""
|
||||
# testing Java serialization of ActorRef
|
||||
pekko.actor.allow-java-serialization = on
|
||||
""") with DefaultTimeout {
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@ object ActorSelectionSpec {
|
|||
|
||||
}
|
||||
|
||||
class ActorSelectionSpec extends AkkaSpec with DefaultTimeout {
|
||||
class ActorSelectionSpec extends PekkoSpec with DefaultTimeout {
|
||||
import ActorSelectionSpec._
|
||||
|
||||
val c1 = system.actorOf(p, "c1")
|
||||
|
|
|
|||
|
|
@ -13,7 +13,7 @@ import org.apache.pekko
|
|||
import pekko.ConfigurationException
|
||||
import pekko.actor.setup.ActorSystemSetup
|
||||
import pekko.dispatch.{ Dispatchers, ExecutionContexts }
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender, TestActors, TestProbe }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec, TestActors, TestProbe }
|
||||
|
||||
object ActorSystemDispatchersSpec {
|
||||
|
||||
|
|
@ -32,7 +32,7 @@ object ActorSystemDispatchersSpec {
|
|||
|
||||
}
|
||||
|
||||
class ActorSystemDispatchersSpec extends AkkaSpec(ConfigFactory.parseString("""
|
||||
class ActorSystemDispatchersSpec extends PekkoSpec(ConfigFactory.parseString("""
|
||||
dispatcher-loop-1 = "dispatcher-loop-2"
|
||||
dispatcher-loop-2 = "dispatcher-loop-1"
|
||||
""")) with ImplicitSender {
|
||||
|
|
|
|||
|
|
@ -116,7 +116,7 @@ object ActorSystemSpec {
|
|||
}
|
||||
|
||||
@nowarn
|
||||
class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSender {
|
||||
class ActorSystemSpec extends PekkoSpec(ActorSystemSpec.config) with ImplicitSender {
|
||||
|
||||
import ActorSystemSpec.FastActor
|
||||
|
||||
|
|
@ -142,7 +142,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
|
||||
"log dead letters" in {
|
||||
val sys =
|
||||
ActorSystem("LogDeadLetters", ConfigFactory.parseString("pekko.loglevel=INFO").withFallback(AkkaSpec.testConf))
|
||||
ActorSystem("LogDeadLetters", ConfigFactory.parseString("pekko.loglevel=INFO").withFallback(PekkoSpec.testConf))
|
||||
try {
|
||||
val probe = TestProbe()(sys)
|
||||
val a = sys.actorOf(Props[ActorSystemSpec.Terminater]())
|
||||
|
|
@ -166,7 +166,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
|
||||
"log dead letters sent without sender reference" in {
|
||||
val sys =
|
||||
ActorSystem("LogDeadLetters", ConfigFactory.parseString("pekko.loglevel=INFO").withFallback(AkkaSpec.testConf))
|
||||
ActorSystem("LogDeadLetters", ConfigFactory.parseString("pekko.loglevel=INFO").withFallback(PekkoSpec.testConf))
|
||||
try {
|
||||
val probe = TestProbe()(sys)
|
||||
val a = sys.actorOf(Props[ActorSystemSpec.Terminater]())
|
||||
|
|
@ -189,7 +189,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
}
|
||||
|
||||
"run termination callbacks in order" in {
|
||||
val system2 = ActorSystem("TerminationCallbacks", AkkaSpec.testConf)
|
||||
val system2 = ActorSystem("TerminationCallbacks", PekkoSpec.testConf)
|
||||
val result = new ConcurrentLinkedQueue[Int]
|
||||
val count = 10
|
||||
val latch = TestLatch(count)
|
||||
|
|
@ -211,7 +211,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
}
|
||||
|
||||
"awaitTermination after termination callbacks" in {
|
||||
val system2 = ActorSystem("AwaitTermination", AkkaSpec.testConf)
|
||||
val system2 = ActorSystem("AwaitTermination", PekkoSpec.testConf)
|
||||
@volatile
|
||||
var callbackWasRun = false
|
||||
|
||||
|
|
@ -240,7 +240,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
}
|
||||
|
||||
"throw RejectedExecutionException when shutdown" in {
|
||||
val system2 = ActorSystem("RejectedExecution-1", AkkaSpec.testConf)
|
||||
val system2 = ActorSystem("RejectedExecution-1", PekkoSpec.testConf)
|
||||
Await.ready(system2.terminate(), 10 seconds)
|
||||
|
||||
intercept[RejectedExecutionException] {
|
||||
|
|
@ -249,7 +249,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
}
|
||||
|
||||
"throw RejectedExecutionException or run termination callback when shutting down" in {
|
||||
val system2 = ActorSystem("RejectedExecution-2", AkkaSpec.testConf)
|
||||
val system2 = ActorSystem("RejectedExecution-2", PekkoSpec.testConf)
|
||||
// using counter to detect double calls
|
||||
val count = new AtomicInteger
|
||||
|
||||
|
|
@ -305,7 +305,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
}
|
||||
|
||||
"shut down when /user fails" in {
|
||||
implicit val system = ActorSystem("Stop", AkkaSpec.testConf)
|
||||
implicit val system = ActorSystem("Stop", PekkoSpec.testConf)
|
||||
EventFilter[ActorKilledException]().intercept {
|
||||
system.actorSelection("/user") ! Kill
|
||||
Await.ready(system.whenTerminated, Duration.Inf)
|
||||
|
|
@ -318,7 +318,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
"Stop",
|
||||
ConfigFactory
|
||||
.parseString("pekko.actor.guardian-supervisor-strategy=org.apache.pekko.actor.StoppingSupervisorStrategy")
|
||||
.withFallback(AkkaSpec.testConf))
|
||||
.withFallback(PekkoSpec.testConf))
|
||||
val a = system.actorOf(Props(new Actor {
|
||||
def receive = {
|
||||
case "die" => throw new Exception("hello")
|
||||
|
|
@ -341,7 +341,7 @@ class ActorSystemSpec extends AkkaSpec(ActorSystemSpec.config) with ImplicitSend
|
|||
"Stop",
|
||||
ConfigFactory
|
||||
.parseString("pekko.actor.guardian-supervisor-strategy=\"org.apache.pekko.actor.ActorSystemSpec$Strategy\"")
|
||||
.withFallback(AkkaSpec.testConf))
|
||||
.withFallback(PekkoSpec.testConf))
|
||||
val a = system.actorOf(Props(new Actor {
|
||||
def receive = {
|
||||
case "die" => throw new Exception("hello")
|
||||
|
|
|
|||
|
|
@ -13,7 +13,7 @@ import pekko.testkit._
|
|||
import pekko.testkit.TestEvent._
|
||||
import pekko.util.Timeout
|
||||
|
||||
class ActorTimeoutSpec extends AkkaSpec {
|
||||
class ActorTimeoutSpec extends PekkoSpec {
|
||||
|
||||
val testTimeout = 200.millis.dilated
|
||||
val leeway = 500.millis.dilated
|
||||
|
|
|
|||
|
|
@ -92,7 +92,7 @@ object ActorWithBoundedStashSpec {
|
|||
}
|
||||
|
||||
class ActorWithBoundedStashSpec
|
||||
extends AkkaSpec(ActorWithBoundedStashSpec.testConf)
|
||||
extends PekkoSpec(ActorWithBoundedStashSpec.testConf)
|
||||
with BeforeAndAfterEach
|
||||
with DefaultTimeout
|
||||
with ImplicitSender {
|
||||
|
|
|
|||
|
|
@ -99,7 +99,7 @@ object ActorWithStashSpec {
|
|||
}
|
||||
|
||||
@nowarn
|
||||
class ActorWithStashSpec extends AkkaSpec with DefaultTimeout with BeforeAndAfterEach {
|
||||
class ActorWithStashSpec extends PekkoSpec with DefaultTimeout with BeforeAndAfterEach {
|
||||
import ActorWithStashSpec._
|
||||
|
||||
override def atStartup(): Unit = {
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.dispatch.ThreadPoolConfig
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
object ConsistencySpec {
|
||||
val minThreads = 1
|
||||
|
|
@ -54,12 +54,12 @@ object ConsistencySpec {
|
|||
}
|
||||
}
|
||||
|
||||
class ConsistencySpec extends AkkaSpec(ConsistencySpec.config) {
|
||||
class ConsistencySpec extends PekkoSpec(ConsistencySpec.config) {
|
||||
import ConsistencySpec._
|
||||
|
||||
override def expectedTestDuration: FiniteDuration = 5.minutes
|
||||
|
||||
"The Akka actor model implementation" must {
|
||||
"The Pekko actor model implementation" must {
|
||||
"provide memory consistency" in {
|
||||
val noOfActors = threads + 1
|
||||
val props = Props[ConsistencyCheckingActor]().withDispatcher("consistency-dispatcher")
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ import pekko.Done
|
|||
import pekko.actor.CoordinatedShutdown.Phase
|
||||
import pekko.actor.CoordinatedShutdown.UnknownReason
|
||||
import pekko.dispatch.ExecutionContexts
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.EventFilter
|
||||
import pekko.testkit.TestKit
|
||||
import pekko.testkit.TestProbe
|
||||
|
|
@ -26,7 +26,7 @@ import scala.concurrent.Future
|
|||
import scala.concurrent.Promise
|
||||
|
||||
class CoordinatedShutdownSpec
|
||||
extends AkkaSpec(ConfigFactory.parseString("""
|
||||
extends PekkoSpec(ConfigFactory.parseString("""
|
||||
pekko.loglevel=INFO
|
||||
pekko.loggers = ["org.apache.pekko.testkit.TestEventListener"]
|
||||
""")) {
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ import scala.concurrent.duration._
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.event.Logging
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.ImplicitSender
|
||||
import pekko.testkit.TestActors
|
||||
import pekko.testkit.TestProbe
|
||||
|
|
@ -21,7 +21,7 @@ object DeadLetterSupressionSpec {
|
|||
|
||||
}
|
||||
|
||||
class DeadLetterSupressionSpec extends AkkaSpec with ImplicitSender {
|
||||
class DeadLetterSupressionSpec extends PekkoSpec with ImplicitSender {
|
||||
import DeadLetterSupressionSpec._
|
||||
|
||||
val deadActor = system.actorOf(TestActors.echoActorProps)
|
||||
|
|
|
|||
|
|
@ -5,7 +5,7 @@
|
|||
package org.apache.pekko.actor
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.EventFilter
|
||||
import pekko.testkit.ImplicitSender
|
||||
import pekko.testkit.TestActors
|
||||
|
|
@ -34,7 +34,7 @@ object DeadLetterSuspensionSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class DeadLetterSuspensionSpec extends AkkaSpec("""
|
||||
class DeadLetterSuspensionSpec extends PekkoSpec("""
|
||||
pekko.loglevel = INFO
|
||||
pekko.log-dead-letters = 4
|
||||
pekko.log-dead-letters-suspend-duration = 2s
|
||||
|
|
|
|||
|
|
@ -16,7 +16,7 @@ import pekko.dispatch.sysmsg.{ DeathWatchNotification, Failed }
|
|||
import pekko.pattern.ask
|
||||
import pekko.testkit._
|
||||
|
||||
class LocalDeathWatchSpec extends AkkaSpec with ImplicitSender with DefaultTimeout with DeathWatchSpec
|
||||
class LocalDeathWatchSpec extends PekkoSpec with ImplicitSender with DefaultTimeout with DeathWatchSpec
|
||||
|
||||
object DeathWatchSpec {
|
||||
object Watcher {
|
||||
|
|
@ -109,7 +109,7 @@ object DeathWatchSpec {
|
|||
}
|
||||
|
||||
@nowarn
|
||||
trait DeathWatchSpec { this: AkkaSpec with ImplicitSender with DefaultTimeout =>
|
||||
trait DeathWatchSpec { this: PekkoSpec with ImplicitSender with DefaultTimeout =>
|
||||
|
||||
import DeathWatchSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.routing._
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
object DeployerSpec {
|
||||
val deployerConf = ConfigFactory.parseString(
|
||||
|
|
@ -79,7 +79,7 @@ object DeployerSpec {
|
|||
|
||||
}
|
||||
|
||||
class DeployerSpec extends AkkaSpec(DeployerSpec.deployerConf) {
|
||||
class DeployerSpec extends PekkoSpec(DeployerSpec.deployerConf) {
|
||||
"A Deployer" must {
|
||||
|
||||
"be able to parse 'pekko.actor.deployment._' with all default values" in {
|
||||
|
|
@ -146,7 +146,7 @@ class DeployerSpec extends AkkaSpec(DeployerSpec.deployerConf) {
|
|||
}
|
||||
""",
|
||||
ConfigParseOptions.defaults)
|
||||
.withFallback(AkkaSpec.testConf)
|
||||
.withFallback(PekkoSpec.testConf)
|
||||
|
||||
shutdown(ActorSystem("invalid-number-of-instances", invalidDeployerConf))
|
||||
}
|
||||
|
|
@ -165,7 +165,7 @@ class DeployerSpec extends AkkaSpec(DeployerSpec.deployerConf) {
|
|||
}
|
||||
""",
|
||||
ConfigParseOptions.defaults)
|
||||
.withFallback(AkkaSpec.testConf)
|
||||
.withFallback(PekkoSpec.testConf)
|
||||
|
||||
shutdown(ActorSystem("invalid-path", invalidDeployerConf))
|
||||
}
|
||||
|
|
|
|||
|
|
@ -101,7 +101,7 @@ object FSMActorSpec {
|
|||
final case class CodeState(soFar: String, code: String)
|
||||
}
|
||||
|
||||
class FSMActorSpec extends AkkaSpec(Map("pekko.actor.debug.fsm" -> true)) with ImplicitSender {
|
||||
class FSMActorSpec extends PekkoSpec(Map("pekko.actor.debug.fsm" -> true)) with ImplicitSender {
|
||||
import FSMActorSpec._
|
||||
|
||||
val timeout = Timeout(2 seconds)
|
||||
|
|
|
|||
|
|
@ -9,7 +9,7 @@ import language.postfixOps
|
|||
import org.apache.pekko.testkit._
|
||||
import scala.concurrent.duration._
|
||||
|
||||
class FSMTimingSpec extends AkkaSpec with ImplicitSender {
|
||||
class FSMTimingSpec extends PekkoSpec with ImplicitSender {
|
||||
import FSMTimingSpec._
|
||||
import FSM._
|
||||
|
||||
|
|
|
|||
|
|
@ -63,7 +63,7 @@ object FSMTransitionSpec {
|
|||
|
||||
}
|
||||
|
||||
class FSMTransitionSpec extends AkkaSpec with ImplicitSender {
|
||||
class FSMTransitionSpec extends PekkoSpec with ImplicitSender {
|
||||
|
||||
import FSMTransitionSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ object ForwardActorSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class ForwardActorSpec extends AkkaSpec {
|
||||
class ForwardActorSpec extends PekkoSpec {
|
||||
import ForwardActorSpec._
|
||||
implicit val ec: ExecutionContextExecutor = system.dispatcher
|
||||
"A Forward Actor" must {
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ package org.apache.pekko.actor
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.dungeon.SerializationCheckFailedException
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.EventFilter
|
||||
import pekko.testkit.ImplicitSender
|
||||
|
||||
|
|
@ -37,7 +37,7 @@ object FunctionRefSpec {
|
|||
|
||||
}
|
||||
|
||||
class FunctionRefSpec extends AkkaSpec("""
|
||||
class FunctionRefSpec extends PekkoSpec("""
|
||||
# test is using Java serialization and relies on serialize-messages=on
|
||||
pekko.actor.allow-java-serialization = on
|
||||
pekko.actor.warn-about-java-serializer-usage = off
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ object HotSwapSpec {
|
|||
abstract class Becomer extends Actor {}
|
||||
}
|
||||
|
||||
class HotSwapSpec extends AkkaSpec with ImplicitSender {
|
||||
class HotSwapSpec extends PekkoSpec with ImplicitSender {
|
||||
import HotSwapSpec.Becomer
|
||||
|
||||
"An Actor" must {
|
||||
|
|
|
|||
|
|
@ -35,7 +35,7 @@ object LocalActorRefProviderSpec {
|
|||
}
|
||||
|
||||
@nowarn
|
||||
class LocalActorRefProviderSpec extends AkkaSpec(LocalActorRefProviderSpec.config) {
|
||||
class LocalActorRefProviderSpec extends PekkoSpec(LocalActorRefProviderSpec.config) {
|
||||
"An LocalActorRefProvider" must {
|
||||
|
||||
"find child actor with URL encoded name" in {
|
||||
|
|
|
|||
|
|
@ -7,7 +7,7 @@ package org.apache.pekko.actor
|
|||
import scala.annotation.nowarn
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.util.unused
|
||||
|
||||
object PropsCreationSpec {
|
||||
|
|
@ -30,7 +30,7 @@ object PropsCreationSpec {
|
|||
|
||||
}
|
||||
|
||||
class PropsCreationSpec extends AkkaSpec("""
|
||||
class PropsCreationSpec extends PekkoSpec("""
|
||||
# test is using Java serialization and relies on serialize-creators=on
|
||||
pekko.actor.serialize-creators = on
|
||||
pekko.actor.no-serialization-verification-needed-class-prefix = []
|
||||
|
|
|
|||
|
|
@ -67,7 +67,7 @@ object ReceiveTimeoutSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class ReceiveTimeoutSpec extends AkkaSpec() {
|
||||
class ReceiveTimeoutSpec extends PekkoSpec() {
|
||||
import ReceiveTimeoutSpec._
|
||||
|
||||
"An actor with receive timeout" must {
|
||||
|
|
|
|||
|
|
@ -14,14 +14,14 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.DefaultTimeout
|
||||
import pekko.testkit.EventFilter
|
||||
import pekko.testkit.TestEvent._
|
||||
import pekko.testkit.TestLatch
|
||||
|
||||
@nowarn
|
||||
class RestartStrategySpec extends AkkaSpec with DefaultTimeout {
|
||||
class RestartStrategySpec extends PekkoSpec with DefaultTimeout {
|
||||
|
||||
override def atStartup(): Unit = {
|
||||
system.eventStream.publish(Mute(EventFilter[Exception]("Crashing...")))
|
||||
|
|
|
|||
|
|
@ -29,11 +29,11 @@ object SchedulerSpec {
|
|||
ConfigFactory.parseString("""
|
||||
pekko.scheduler.implementation = org.apache.pekko.actor.LightArrayRevolverScheduler
|
||||
pekko.scheduler.ticks-per-wheel = 32
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
}
|
||||
|
||||
trait SchedulerSpec extends BeforeAndAfterEach with DefaultTimeout with ImplicitSender { this: AkkaSpec =>
|
||||
trait SchedulerSpec extends BeforeAndAfterEach with DefaultTimeout with ImplicitSender { this: PekkoSpec =>
|
||||
import system.dispatcher
|
||||
|
||||
def collectCancellable(c: Cancellable): Cancellable
|
||||
|
|
@ -419,7 +419,7 @@ trait SchedulerSpec extends BeforeAndAfterEach with DefaultTimeout with Implicit
|
|||
}
|
||||
}
|
||||
|
||||
class LightArrayRevolverSchedulerSpec extends AkkaSpec(SchedulerSpec.testConfRevolver) with SchedulerSpec {
|
||||
class LightArrayRevolverSchedulerSpec extends PekkoSpec(SchedulerSpec.testConfRevolver) with SchedulerSpec {
|
||||
|
||||
def collectCancellable(c: Cancellable): Cancellable = c
|
||||
|
||||
|
|
|
|||
|
|
@ -25,7 +25,7 @@ import pekko.actor.SupervisorStrategy.seqThrowable2Decider
|
|||
import pekko.dispatch.{ Dispatcher, DispatcherConfigurator, DispatcherPrerequisites, MessageDispatcher }
|
||||
import pekko.event.Logging
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout, EventFilter, ImplicitSender }
|
||||
import pekko.testkit.{ DefaultTimeout, EventFilter, ImplicitSender, PekkoSpec }
|
||||
import pekko.testkit.{ filterEvents, filterException, TestDuration, TestLatch }
|
||||
import pekko.testkit.LongRunningTest
|
||||
import pekko.testkit.TestEvent.Mute
|
||||
|
|
@ -748,7 +748,8 @@ object SupervisorHierarchySpec {
|
|||
|
||||
}
|
||||
|
||||
class SupervisorHierarchySpec extends AkkaSpec(SupervisorHierarchySpec.config) with DefaultTimeout with ImplicitSender {
|
||||
class SupervisorHierarchySpec extends PekkoSpec(SupervisorHierarchySpec.config) with DefaultTimeout
|
||||
with ImplicitSender {
|
||||
import SupervisorHierarchySpec._
|
||||
|
||||
override def expectedTestDuration = 2.minutes
|
||||
|
|
|
|||
|
|
@ -16,7 +16,7 @@ import language.postfixOps
|
|||
import org.apache.pekko
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.{ filterEvents, EventFilter }
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.DefaultTimeout
|
||||
|
||||
object SupervisorMiscSpec {
|
||||
|
|
@ -31,7 +31,7 @@ object SupervisorMiscSpec {
|
|||
}
|
||||
|
||||
@nowarn
|
||||
class SupervisorMiscSpec extends AkkaSpec(SupervisorMiscSpec.config) with DefaultTimeout {
|
||||
class SupervisorMiscSpec extends PekkoSpec(SupervisorMiscSpec.config) with DefaultTimeout {
|
||||
|
||||
"A Supervisor" must {
|
||||
|
||||
|
|
|
|||
|
|
@ -106,7 +106,7 @@ object SupervisorSpec {
|
|||
}
|
||||
|
||||
class SupervisorSpec
|
||||
extends AkkaSpec(SupervisorSpec.config)
|
||||
extends PekkoSpec(SupervisorSpec.config)
|
||||
with BeforeAndAfterEach
|
||||
with ImplicitSender
|
||||
with DefaultTimeout {
|
||||
|
|
|
|||
|
|
@ -11,9 +11,9 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout, EventFilter, ImplicitSender }
|
||||
import pekko.testkit.{ DefaultTimeout, EventFilter, ImplicitSender, PekkoSpec }
|
||||
|
||||
class SupervisorTreeSpec extends AkkaSpec with ImplicitSender with DefaultTimeout {
|
||||
class SupervisorTreeSpec extends PekkoSpec with ImplicitSender with DefaultTimeout {
|
||||
|
||||
"In a 3 levels deep supervisor tree (linked in the constructor) we" must {
|
||||
|
||||
|
|
|
|||
|
|
@ -13,11 +13,11 @@ import org.scalatest.BeforeAndAfterAll
|
|||
import org.apache.pekko
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.{ filterEvents, EventFilter }
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.DefaultTimeout
|
||||
import pekko.testkit.ImplicitSender
|
||||
|
||||
class Ticket669Spec extends AkkaSpec with BeforeAndAfterAll with ImplicitSender with DefaultTimeout {
|
||||
class Ticket669Spec extends PekkoSpec with BeforeAndAfterAll with ImplicitSender with DefaultTimeout {
|
||||
import Ticket669Spec._
|
||||
|
||||
// TODO: does this really make sense?
|
||||
|
|
|
|||
|
|
@ -177,7 +177,7 @@ class FsmTimerSpec extends AbstractTimerSpec {
|
|||
TimerSpec.fsmTarget(monitor, interval, repeat, initial)
|
||||
}
|
||||
|
||||
abstract class AbstractTimerSpec extends AkkaSpec {
|
||||
abstract class AbstractTimerSpec extends PekkoSpec {
|
||||
import TimerSpec._
|
||||
|
||||
val interval = 1.second
|
||||
|
|
@ -312,7 +312,7 @@ object TimersAndStashSpec {
|
|||
case object StopStashing
|
||||
|
||||
}
|
||||
class TimersAndStashSpec extends AkkaSpec {
|
||||
class TimersAndStashSpec extends PekkoSpec {
|
||||
import TimersAndStashSpec._
|
||||
|
||||
class ActorWithTimerAndStash(probe: ActorRef) extends Actor with Timers with Stash {
|
||||
|
|
|
|||
|
|
@ -22,7 +22,7 @@ import pekko.japi.{ Option => JOption }
|
|||
import pekko.pattern.ask
|
||||
import pekko.routing.RoundRobinGroup
|
||||
import pekko.serialization.{ JavaSerializer, SerializerWithStringManifest }
|
||||
import pekko.testkit.{ filterEvents, AkkaSpec, DefaultTimeout, EventFilter, TimingTest }
|
||||
import pekko.testkit.{ filterEvents, DefaultTimeout, EventFilter, PekkoSpec, TimingTest }
|
||||
import pekko.util.Timeout
|
||||
|
||||
object TypedActorSpec {
|
||||
|
|
@ -251,7 +251,7 @@ object TypedActorSpec {
|
|||
|
||||
@nowarn
|
||||
class TypedActorSpec
|
||||
extends AkkaSpec(TypedActorSpec.config)
|
||||
extends PekkoSpec(TypedActorSpec.config)
|
||||
with BeforeAndAfterEach
|
||||
with BeforeAndAfterAll
|
||||
with DefaultTimeout {
|
||||
|
|
@ -577,7 +577,7 @@ class TypedActorSpec
|
|||
|
||||
@nowarn
|
||||
class TypedActorRouterSpec
|
||||
extends AkkaSpec(TypedActorSpec.config)
|
||||
extends PekkoSpec(TypedActorSpec.config)
|
||||
with BeforeAndAfterEach
|
||||
with BeforeAndAfterAll
|
||||
with DefaultTimeout {
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ import org.apache.pekko
|
|||
import pekko.actor.SupervisorStrategy.{ Restart, Stop }
|
||||
import pekko.dispatch.sysmsg.SystemMessage
|
||||
import pekko.event.EventStream
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
|
||||
object UidClashTest {
|
||||
|
||||
|
|
@ -88,7 +88,7 @@ object UidClashTest {
|
|||
|
||||
}
|
||||
|
||||
class UidClashTest extends AkkaSpec {
|
||||
class UidClashTest extends PekkoSpec {
|
||||
import UidClashTest._
|
||||
|
||||
"The Terminated message for an old child stopped in preRestart" should {
|
||||
|
|
|
|||
|
|
@ -254,7 +254,7 @@ object ActorModelSpec {
|
|||
} else throw new AssertionError("await failed")
|
||||
}
|
||||
|
||||
abstract class ActorModelSpec(config: String) extends AkkaSpec(config) with DefaultTimeout {
|
||||
abstract class ActorModelSpec(config: String) extends PekkoSpec(config) with DefaultTimeout {
|
||||
|
||||
import ActorModelSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ import java.util.concurrent.{ CountDownLatch, TimeUnit }
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, ActorCell, ActorRefWithCell, Props }
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
object BalancingDispatcherSpec {
|
||||
val config = """
|
||||
|
|
@ -19,7 +19,7 @@ object BalancingDispatcherSpec {
|
|||
"""
|
||||
}
|
||||
|
||||
class BalancingDispatcherSpec extends AkkaSpec(BalancingDispatcherSpec.config) {
|
||||
class BalancingDispatcherSpec extends PekkoSpec(BalancingDispatcherSpec.config) {
|
||||
|
||||
val delayableActorDispatcher = "pooled-dispatcher"
|
||||
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ import language.postfixOps
|
|||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.DefaultTimeout
|
||||
|
||||
object DispatcherActorSpec {
|
||||
|
|
@ -56,7 +56,7 @@ object DispatcherActorSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class DispatcherActorSpec extends AkkaSpec(DispatcherActorSpec.config) with DefaultTimeout {
|
||||
class DispatcherActorSpec extends PekkoSpec(DispatcherActorSpec.config) with DefaultTimeout {
|
||||
import DispatcherActorSpec._
|
||||
|
||||
"A Dispatcher and an Actor" must {
|
||||
|
|
|
|||
|
|
@ -8,12 +8,12 @@ import java.util.concurrent.CountDownLatch
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor._
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
/**
|
||||
* Tests the behavior of the executor based event driven dispatcher when multiple actors are being dispatched on it.
|
||||
*/
|
||||
class DispatcherActorsSpec extends AkkaSpec {
|
||||
class DispatcherActorsSpec extends PekkoSpec {
|
||||
class SlowActor(finishedCounter: CountDownLatch) extends Actor {
|
||||
|
||||
def receive = {
|
||||
|
|
|
|||
|
|
@ -17,7 +17,7 @@ import pekko.ConfigurationException
|
|||
import pekko.actor._
|
||||
import pekko.dispatch._
|
||||
import pekko.routing.FromConfig
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec }
|
||||
import pekko.util.unused
|
||||
|
||||
object DispatchersSpec {
|
||||
|
|
@ -101,7 +101,7 @@ object DispatchersSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class DispatchersSpec extends AkkaSpec(DispatchersSpec.config) with ImplicitSender {
|
||||
class DispatchersSpec extends PekkoSpec(DispatchersSpec.config) with ImplicitSender {
|
||||
import DispatchersSpec._
|
||||
val df = system.dispatchers
|
||||
import df._
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ import org.apache.pekko
|
|||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.pattern.ask
|
||||
import pekko.testkit._
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
object PinnedActorSpec {
|
||||
val config = """
|
||||
|
|
@ -32,7 +32,7 @@ object PinnedActorSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class PinnedActorSpec extends AkkaSpec(PinnedActorSpec.config) with BeforeAndAfterEach with DefaultTimeout {
|
||||
class PinnedActorSpec extends PekkoSpec(PinnedActorSpec.config) with BeforeAndAfterEach with DefaultTimeout {
|
||||
import PinnedActorSpec._
|
||||
|
||||
"A PinnedActor" must {
|
||||
|
|
|
|||
|
|
@ -17,7 +17,7 @@ object DispatchSpec {
|
|||
}
|
||||
}
|
||||
}
|
||||
class DispatchSpec extends AkkaSpec("""
|
||||
class DispatchSpec extends PekkoSpec("""
|
||||
pekko.actor.serialize-messages = on
|
||||
pekko.actor.no-serialization-verification-needed-class-prefix = []
|
||||
""") with DefaultTimeout {
|
||||
|
|
|
|||
|
|
@ -13,7 +13,7 @@ import pekko.actor._
|
|||
import pekko.routing._
|
||||
import pekko.testkit._
|
||||
|
||||
class ListenerSpec extends AkkaSpec {
|
||||
class ListenerSpec extends PekkoSpec {
|
||||
|
||||
"Listener" must {
|
||||
|
||||
|
|
|
|||
|
|
@ -16,9 +16,9 @@ import pekko.actor.ActorSystem
|
|||
import pekko.actor.ExtendedActorSystem
|
||||
import pekko.event.DefaultLoggingFilter
|
||||
import pekko.event.Logging.DefaultLogger
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
class ConfigSpec extends AkkaSpec(ConfigFactory.defaultReference(ActorSystem.findClassLoader())) with Assertions {
|
||||
class ConfigSpec extends PekkoSpec(ConfigFactory.defaultReference(ActorSystem.findClassLoader())) with Assertions {
|
||||
|
||||
"The default configuration file (i.e. reference.conf)" must {
|
||||
"contain all configuration properties for akka-actor that are used in code with their correct defaults" in {
|
||||
|
|
|
|||
|
|
@ -16,9 +16,9 @@ import org.apache.pekko
|
|||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.actor.ActorRef
|
||||
import pekko.pattern.{ ask, pipe }
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout }
|
||||
import pekko.testkit.{ DefaultTimeout, PekkoSpec }
|
||||
|
||||
class Future2ActorSpec extends AkkaSpec with DefaultTimeout {
|
||||
class Future2ActorSpec extends PekkoSpec with DefaultTimeout {
|
||||
implicit val ec: ExecutionContextExecutor = system.dispatcher
|
||||
"The Future2Actor bridge" must {
|
||||
|
||||
|
|
|
|||
|
|
@ -6,7 +6,7 @@ package org.apache.pekko.dispatch
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout }
|
||||
import pekko.testkit.{ DefaultTimeout, PekkoSpec }
|
||||
|
||||
object ControlAwareDispatcherSpec {
|
||||
val config = """
|
||||
|
|
@ -21,7 +21,7 @@ object ControlAwareDispatcherSpec {
|
|||
case object ImportantMessage extends ControlMessage
|
||||
}
|
||||
|
||||
class ControlAwareDispatcherSpec extends AkkaSpec(ControlAwareDispatcherSpec.config) with DefaultTimeout {
|
||||
class ControlAwareDispatcherSpec extends PekkoSpec(ControlAwareDispatcherSpec.config) with DefaultTimeout {
|
||||
import ControlAwareDispatcherSpec.ImportantMessage
|
||||
|
||||
"A ControlAwareDispatcher" must {
|
||||
|
|
|
|||
|
|
@ -14,13 +14,13 @@ import scala.concurrent.duration._
|
|||
import org.apache.pekko
|
||||
import pekko.actor.Actor
|
||||
import pekko.actor.Props
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout, TestLatch }
|
||||
import pekko.testkit.{ DefaultTimeout, PekkoSpec, TestLatch }
|
||||
import pekko.testkit.CallingThreadDispatcher
|
||||
import pekko.testkit.TestActorRef
|
||||
import pekko.testkit.TestProbe
|
||||
import pekko.util.SerializedSuspendableExecutionContext
|
||||
|
||||
class ExecutionContextSpec extends AkkaSpec with DefaultTimeout {
|
||||
class ExecutionContextSpec extends PekkoSpec with DefaultTimeout {
|
||||
|
||||
"An ExecutionContext" must {
|
||||
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ import com.typesafe.config.ConfigFactory
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec }
|
||||
|
||||
object ForkJoinPoolStarvationSpec {
|
||||
val config = ConfigFactory.parseString("""
|
||||
|
|
@ -44,12 +44,12 @@ object ForkJoinPoolStarvationSpec {
|
|||
|
||||
}
|
||||
|
||||
class ForkJoinPoolStarvationSpec extends AkkaSpec(ForkJoinPoolStarvationSpec.config) with ImplicitSender {
|
||||
class ForkJoinPoolStarvationSpec extends PekkoSpec(ForkJoinPoolStarvationSpec.config) with ImplicitSender {
|
||||
import ForkJoinPoolStarvationSpec._
|
||||
|
||||
val Iterations = 1000
|
||||
|
||||
"AkkaForkJoinPool" must {
|
||||
"PekkoForkJoinPool" must {
|
||||
|
||||
"not starve tasks arriving from external dispatchers under high internal traffic" in {
|
||||
// TODO issue #31117: starvation with JDK 17 FJP
|
||||
|
|
|
|||
|
|
@ -15,10 +15,10 @@ import org.scalatest.{ BeforeAndAfterAll, BeforeAndAfterEach }
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor._
|
||||
import pekko.testkit.{ AkkaSpec, EventFilter }
|
||||
import pekko.testkit.{ EventFilter, PekkoSpec }
|
||||
import pekko.util.unused
|
||||
|
||||
abstract class MailboxSpec extends AkkaSpec with BeforeAndAfterAll with BeforeAndAfterEach {
|
||||
abstract class MailboxSpec extends PekkoSpec with BeforeAndAfterAll with BeforeAndAfterEach {
|
||||
def name: String
|
||||
|
||||
def factory: MailboxType => MessageQueue
|
||||
|
|
@ -244,7 +244,7 @@ object CustomMailboxSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class CustomMailboxSpec extends AkkaSpec(CustomMailboxSpec.config) {
|
||||
class CustomMailboxSpec extends PekkoSpec(CustomMailboxSpec.config) {
|
||||
"Dispatcher configuration" must {
|
||||
"support custom mailboxType" in {
|
||||
val actor = system.actorOf(Props.empty.withDispatcher("my-dispatcher"))
|
||||
|
|
@ -283,7 +283,7 @@ object SingleConsumerOnlyMailboxVerificationSpec {
|
|||
}
|
||||
|
||||
class SingleConsumerOnlyMailboxVerificationSpec
|
||||
extends AkkaSpec(SingleConsumerOnlyMailboxVerificationSpec.mailboxConf) {
|
||||
extends PekkoSpec(SingleConsumerOnlyMailboxVerificationSpec.mailboxConf) {
|
||||
import SingleConsumerOnlyMailboxVerificationSpec.Ping
|
||||
|
||||
def pathologicalPingPong(dispatcherId: String): Unit = {
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, ActorSystem, Props }
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout }
|
||||
import pekko.testkit.{ DefaultTimeout, PekkoSpec }
|
||||
import pekko.util.unused
|
||||
|
||||
object PriorityDispatcherSpec {
|
||||
|
|
@ -43,7 +43,7 @@ object PriorityDispatcherSpec {
|
|||
|
||||
}
|
||||
|
||||
class PriorityDispatcherSpec extends AkkaSpec(PriorityDispatcherSpec.config) with DefaultTimeout {
|
||||
class PriorityDispatcherSpec extends PekkoSpec(PriorityDispatcherSpec.config) with DefaultTimeout {
|
||||
import PriorityDispatcherSpec._
|
||||
|
||||
"A PriorityDispatcher" must {
|
||||
|
|
|
|||
|
|
@ -12,9 +12,9 @@ import org.scalatest.matchers.should.Matchers
|
|||
import org.apache.pekko
|
||||
import pekko.Done
|
||||
import pekko.dispatch.internal.SameThreadExecutionContext
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
class SameThreadExecutionContextSpec extends AkkaSpec with Matchers {
|
||||
class SameThreadExecutionContextSpec extends PekkoSpec with Matchers {
|
||||
|
||||
"The SameThreadExecutionContext" should {
|
||||
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, ActorSystem, Props }
|
||||
import pekko.testkit.{ AkkaSpec, DefaultTimeout }
|
||||
import pekko.testkit.{ DefaultTimeout, PekkoSpec }
|
||||
import pekko.util.unused
|
||||
|
||||
object StablePriorityDispatcherSpec {
|
||||
|
|
@ -44,7 +44,7 @@ object StablePriorityDispatcherSpec {
|
|||
|
||||
}
|
||||
|
||||
class StablePriorityDispatcherSpec extends AkkaSpec(StablePriorityDispatcherSpec.config) with DefaultTimeout {
|
||||
class StablePriorityDispatcherSpec extends PekkoSpec(StablePriorityDispatcherSpec.config) with DefaultTimeout {
|
||||
import StablePriorityDispatcherSpec._
|
||||
|
||||
"A StablePriorityDispatcher" must {
|
||||
|
|
|
|||
|
|
@ -6,9 +6,9 @@ package org.apache.pekko.dispatch.sysmsg
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.Props
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
class SystemMessageListSpec extends AkkaSpec {
|
||||
class SystemMessageListSpec extends PekkoSpec {
|
||||
import SystemMessageList.ENil
|
||||
import SystemMessageList.LNil
|
||||
|
||||
|
|
|
|||
|
|
@ -27,7 +27,7 @@ object AddressTerminatedTopicBenchSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class AddressTerminatedTopicBenchSpec extends AkkaSpec("pekko.loglevel=INFO") {
|
||||
class AddressTerminatedTopicBenchSpec extends PekkoSpec("pekko.loglevel=INFO") {
|
||||
import AddressTerminatedTopicBenchSpec._
|
||||
|
||||
"Subscribe and unsubscribe of AddressTerminated" must {
|
||||
|
|
|
|||
|
|
@ -21,7 +21,7 @@ object EventBusSpec {
|
|||
}
|
||||
|
||||
abstract class EventBusSpec(busName: String, conf: Config = ConfigFactory.empty())
|
||||
extends AkkaSpec(conf)
|
||||
extends PekkoSpec(conf)
|
||||
with BeforeAndAfterEach {
|
||||
type BusType <: EventBus
|
||||
|
||||
|
|
@ -172,7 +172,7 @@ class ActorEventBusSpec(conf: Config) extends EventBusSpec("ActorEventBus", conf
|
|||
import org.apache.pekko.event.ActorEventBusSpec._
|
||||
|
||||
def this() =
|
||||
this(ConfigFactory.parseString("pekko.actor.debug.event-stream = on").withFallback(AkkaSpec.testConf))
|
||||
this(ConfigFactory.parseString("pekko.actor.debug.event-stream = on").withFallback(PekkoSpec.testConf))
|
||||
|
||||
type BusType = MyActorEventBus
|
||||
def createNewEventBus(): BusType = new MyActorEventBus(system)
|
||||
|
|
|
|||
|
|
@ -10,7 +10,7 @@ import com.typesafe.config.ConfigFactory
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor._
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
|
||||
object EventStreamSpec {
|
||||
|
||||
|
|
@ -66,7 +66,7 @@ object EventStreamSpec {
|
|||
class CCATBT extends CC with ATT with BTT
|
||||
}
|
||||
|
||||
class EventStreamSpec extends AkkaSpec(EventStreamSpec.config) {
|
||||
class EventStreamSpec extends PekkoSpec(EventStreamSpec.config) {
|
||||
|
||||
import EventStreamSpec._
|
||||
|
||||
|
|
|
|||
|
|
@ -34,7 +34,7 @@ object LoggerSpec {
|
|||
loglevel = "DEBUG" # test verifies debug
|
||||
loggers = ["org.apache.pekko.event.LoggerSpec$TestLogger1"]
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
val slowConfig = ConfigFactory.parseString("""
|
||||
pekko {
|
||||
|
|
@ -42,7 +42,7 @@ object LoggerSpec {
|
|||
loglevel = "ERROR"
|
||||
loggers = ["org.apache.pekko.event.LoggerSpec$SlowLogger"]
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
val noLoggingConfig = ConfigFactory.parseString("""
|
||||
pekko {
|
||||
|
|
@ -50,7 +50,7 @@ object LoggerSpec {
|
|||
loglevel = "OFF"
|
||||
loggers = ["org.apache.pekko.event.LoggerSpec$TestLogger1"]
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
val multipleConfig =
|
||||
ConfigFactory.parseString("""
|
||||
|
|
@ -59,7 +59,7 @@ object LoggerSpec {
|
|||
loglevel = "WARNING"
|
||||
loggers = ["org.apache.pekko.event.LoggerSpec$TestLogger1", "org.apache.pekko.event.LoggerSpec$TestLogger2"]
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
val ticket3165Config = ConfigFactory.parseString(s"""
|
||||
pekko {
|
||||
|
|
@ -75,7 +75,7 @@ object LoggerSpec {
|
|||
}
|
||||
}
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
val ticket3671Config = ConfigFactory.parseString("""
|
||||
pekko {
|
||||
|
|
@ -83,7 +83,7 @@ object LoggerSpec {
|
|||
loglevel = "WARNING"
|
||||
loggers = ["org.apache.pekko.event.LoggerSpec$TestLogger1"]
|
||||
}
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
|
||||
final case class SetTarget(ref: ActorRef, qualifier: Int)
|
||||
|
||||
|
|
|
|||
|
|
@ -30,7 +30,7 @@ class LoggingReceiveSpec extends AnyWordSpec with BeforeAndAfterAll {
|
|||
import LoggingReceiveSpec._
|
||||
val config = ConfigFactory.parseString("""
|
||||
pekko.loglevel=DEBUG # test verifies debug
|
||||
""").withFallback(AkkaSpec.testConf)
|
||||
""").withFallback(PekkoSpec.testConf)
|
||||
val appLogging =
|
||||
ActorSystem("logging", ConfigFactory.parseMap(Map("pekko.actor.debug.receive" -> true).asJava).withFallback(config))
|
||||
val appAuto = ActorSystem(
|
||||
|
|
|
|||
|
|
@ -8,7 +8,7 @@ import org.apache.pekko
|
|||
import pekko.event.Logging._
|
||||
import pekko.testkit._
|
||||
|
||||
class MarkerLoggingSpec extends AkkaSpec with ImplicitSender {
|
||||
class MarkerLoggingSpec extends PekkoSpec with ImplicitSender {
|
||||
"A MarkerLoggerAdapter" should {
|
||||
val markerLogging = new MarkerLoggingAdapter(
|
||||
system.eventStream,
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ import com.typesafe.config.ConfigFactory
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, ActorLogging, Props }
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
@deprecated("Use SLF4J instead.", "2.6.0")
|
||||
object JavaLoggerSpec {
|
||||
|
|
@ -37,7 +37,7 @@ object JavaLoggerSpec {
|
|||
}
|
||||
|
||||
@deprecated("Use SLF4J instead.", "2.6.0")
|
||||
class JavaLoggerSpec extends AkkaSpec(JavaLoggerSpec.config) {
|
||||
class JavaLoggerSpec extends PekkoSpec(JavaLoggerSpec.config) {
|
||||
|
||||
val logger = logging.Logger.getLogger(classOf[JavaLoggerSpec.LogProducer].getName)
|
||||
logger.setUseParentHandlers(false) // turn off output of test LogRecords
|
||||
|
|
|
|||
|
|
@ -7,10 +7,10 @@ package org.apache.pekko.io
|
|||
import Tcp._
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
import pekko.testkit.SocketUtil.temporaryServerAddresses
|
||||
|
||||
class CapacityLimitSpec extends AkkaSpec("""
|
||||
class CapacityLimitSpec extends PekkoSpec("""
|
||||
pekko.loglevel = ERROR
|
||||
pekko.io.tcp.max-channels = 4
|
||||
""") with TcpIntegrationSpecSupport {
|
||||
|
|
|
|||
|
|
@ -11,10 +11,10 @@ import scala.annotation.nowarn
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.Props
|
||||
import pekko.testkit.{ AkkaSpec, TestActorRef }
|
||||
import pekko.testkit.{ PekkoSpec, TestActorRef }
|
||||
|
||||
@nowarn
|
||||
class InetAddressDnsResolverSpec extends AkkaSpec("""
|
||||
class InetAddressDnsResolverSpec extends PekkoSpec("""
|
||||
pekko.io.dns.inet-address.positive-ttl = default
|
||||
pekko.io.dns.inet-address.negative-ttl = default
|
||||
""") { thisSpecs =>
|
||||
|
|
@ -122,7 +122,7 @@ class InetAddressDnsResolverSpec extends AkkaSpec("""
|
|||
}
|
||||
|
||||
@nowarn
|
||||
class InetAddressDnsResolverConfigSpec extends AkkaSpec("""
|
||||
class InetAddressDnsResolverConfigSpec extends PekkoSpec("""
|
||||
pekko.io.dns.inet-address.positive-ttl = forever
|
||||
pekko.io.dns.inet-address.negative-ttl = never
|
||||
""") {
|
||||
|
|
|
|||
|
|
@ -29,7 +29,7 @@ import pekko.actor._
|
|||
import pekko.io.Inet.SocketOption
|
||||
import pekko.io.SelectionHandler._
|
||||
import pekko.io.Tcp._
|
||||
import pekko.testkit.{ AkkaSpec, EventFilter, SocketUtil, TestActorRef, TestProbe }
|
||||
import pekko.testkit.{ EventFilter, PekkoSpec, SocketUtil, TestActorRef, TestProbe }
|
||||
import pekko.testkit.SocketUtil.temporaryServerAddress
|
||||
import pekko.testkit.WithLogCapturing
|
||||
import pekko.util.{ ByteString, Helpers }
|
||||
|
|
@ -40,7 +40,7 @@ object TcpConnectionSpec {
|
|||
final case class Registration(channel: SelectableChannel, initialOps: Int) extends NoSerializationVerificationNeeded
|
||||
}
|
||||
|
||||
class TcpConnectionSpec extends AkkaSpec("""
|
||||
class TcpConnectionSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
pekko.io.tcp.trace-logging = on
|
||||
|
|
@ -377,7 +377,7 @@ class TcpConnectionSpec extends AkkaSpec("""
|
|||
"respect pull mode" in new EstablishedConnectionTest(pullMode = true) {
|
||||
// override config to decrease default buffer size
|
||||
def config =
|
||||
ConfigFactory.parseString("pekko.io.tcp.direct-buffer-size = 1k").withFallback(AkkaSpec.testConf)
|
||||
ConfigFactory.parseString("pekko.io.tcp.direct-buffer-size = 1k").withFallback(PekkoSpec.testConf)
|
||||
override implicit lazy val system: ActorSystem = ActorSystem("respectPullModeTest", config)
|
||||
|
||||
try run {
|
||||
|
|
|
|||
|
|
@ -15,11 +15,11 @@ import org.scalatest.concurrent.TimeLimits
|
|||
import org.apache.pekko
|
||||
import pekko.actor.{ ActorRef, PoisonPill }
|
||||
import pekko.io.Tcp._
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
import pekko.testkit.WithLogCapturing
|
||||
import pekko.util.ByteString
|
||||
|
||||
class TcpIntegrationSpec extends AkkaSpec("""
|
||||
class TcpIntegrationSpec extends PekkoSpec("""
|
||||
pekko.loglevel = debug
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
pekko.io.tcp.trace-logging = on
|
||||
|
|
|
|||
|
|
@ -14,10 +14,10 @@ import pekko.actor.ActorRef
|
|||
import pekko.actor.ActorSystem
|
||||
import pekko.dispatch.ExecutionContexts
|
||||
import pekko.io.Inet.SocketOption
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
import pekko.testkit.SocketUtil.temporaryServerAddress
|
||||
|
||||
trait TcpIntegrationSpecSupport { this: AkkaSpec =>
|
||||
trait TcpIntegrationSpecSupport { this: PekkoSpec =>
|
||||
|
||||
class TestSetup(shouldBindServer: Boolean = true, runClientInExtraSystem: Boolean = true) {
|
||||
val clientSystem =
|
||||
|
|
|
|||
|
|
@ -17,10 +17,10 @@ import pekko.actor._
|
|||
import pekko.io.SelectionHandler._
|
||||
import pekko.io.TcpListener.{ FailedRegisterIncoming, RegisterIncoming }
|
||||
import pekko.io.TcpListenerSpec.RegisterChannel
|
||||
import pekko.testkit.{ AkkaSpec, EventFilter, TestActorRef, TestProbe }
|
||||
import pekko.testkit.{ EventFilter, PekkoSpec, TestActorRef, TestProbe }
|
||||
import pekko.testkit.SocketUtil
|
||||
|
||||
class TcpListenerSpec extends AkkaSpec("""
|
||||
class TcpListenerSpec extends PekkoSpec("""
|
||||
pekko.io.tcp.batch-accept-limit = 2
|
||||
""") {
|
||||
|
||||
|
|
|
|||
|
|
@ -10,14 +10,14 @@ import scala.concurrent.duration._
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.ActorRef
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.ImplicitSender
|
||||
import pekko.testkit.SocketUtil.temporaryServerAddresses
|
||||
import pekko.testkit.TestProbe
|
||||
import pekko.testkit.WithLogCapturing
|
||||
import pekko.util.ByteString
|
||||
|
||||
class UdpConnectedIntegrationSpec extends AkkaSpec("""
|
||||
class UdpConnectedIntegrationSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.actor.debug.lifecycle = on
|
||||
pekko.actor.debug.autoreceive = on
|
||||
|
|
|
|||
|
|
@ -10,11 +10,11 @@ import org.apache.pekko
|
|||
import pekko.actor.ActorRef
|
||||
import pekko.io.Inet._
|
||||
import pekko.io.Udp._
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec, TestProbe }
|
||||
import pekko.testkit.SocketUtil.temporaryServerAddresses
|
||||
import pekko.util.ByteString
|
||||
|
||||
class UdpIntegrationSpec extends AkkaSpec("""
|
||||
class UdpIntegrationSpec extends PekkoSpec("""
|
||||
pekko.loglevel = INFO
|
||||
# tests expect to be able to mutate messages
|
||||
""") with ImplicitSender {
|
||||
|
|
|
|||
|
|
@ -12,9 +12,9 @@ import com.typesafe.config.ConfigFactory
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.ExtendedActorSystem
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
|
||||
class DnsSettingsSpec extends AkkaSpec {
|
||||
class DnsSettingsSpec extends PekkoSpec {
|
||||
|
||||
val eas = system.asInstanceOf[ExtendedActorSystem]
|
||||
|
||||
|
|
|
|||
|
|
@ -15,10 +15,10 @@ import com.spotify.docker.client.messages.{ ContainerConfig, HostConfig, PortBin
|
|||
import org.scalatest.concurrent.Eventually
|
||||
|
||||
import org.apache.pekko
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.util.ccompat.JavaConverters._
|
||||
|
||||
abstract class DockerBindDnsService(config: Config) extends AkkaSpec(config) with Eventually {
|
||||
abstract class DockerBindDnsService(config: Config) extends PekkoSpec(config) with Eventually {
|
||||
val client = DefaultDockerClient.fromEnv().build()
|
||||
|
||||
val hostPort: Int
|
||||
|
|
|
|||
|
|
@ -15,12 +15,12 @@ import pekko.io.Dns
|
|||
import pekko.io.dns.AAAARecord
|
||||
import pekko.io.dns.CachePolicy.Ttl
|
||||
import pekko.io.dns.DnsProtocol.{ Resolve, Resolved }
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec }
|
||||
import pekko.testkit.WithLogCapturing
|
||||
|
||||
// tests deprecated DNS API
|
||||
@nowarn("msg=deprecated")
|
||||
class AsyncDnsManagerSpec extends AkkaSpec("""
|
||||
class AsyncDnsManagerSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
pekko.io.dns.resolver = async-dns
|
||||
|
|
|
|||
|
|
@ -20,9 +20,9 @@ import pekko.io.dns.CachePolicy.Ttl
|
|||
import pekko.io.dns.DnsProtocol._
|
||||
import pekko.io.dns.internal.AsyncDnsResolver.ResolveFailedException
|
||||
import pekko.io.dns.internal.DnsClient.{ Answer, Question4, Question6, SrvQuestion }
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe, WithLogCapturing }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe, WithLogCapturing }
|
||||
|
||||
class AsyncDnsResolverSpec extends AkkaSpec("""
|
||||
class AsyncDnsResolverSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
""") with WithLogCapturing {
|
||||
|
|
|
|||
|
|
@ -14,9 +14,9 @@ import pekko.actor.Props
|
|||
import pekko.io.Udp
|
||||
import pekko.io.dns.{ RecordClass, RecordType }
|
||||
import pekko.io.dns.internal.DnsClient.{ Answer, Question4 }
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec, TestProbe }
|
||||
|
||||
class DnsClientSpec extends AkkaSpec with ImplicitSender {
|
||||
class DnsClientSpec extends PekkoSpec with ImplicitSender {
|
||||
"The async DNS client" should {
|
||||
val exampleRequest = Question4(42, "pekko.io")
|
||||
val exampleRequestMessage =
|
||||
|
|
|
|||
|
|
@ -14,9 +14,9 @@ import pekko.io.Tcp
|
|||
import pekko.io.Tcp.{ Connected, PeerClosed, Register }
|
||||
import pekko.io.dns.{ RecordClass, RecordType }
|
||||
import pekko.io.dns.internal.DnsClient.Answer
|
||||
import pekko.testkit.{ AkkaSpec, ImplicitSender, TestProbe }
|
||||
import pekko.testkit.{ ImplicitSender, PekkoSpec, TestProbe }
|
||||
|
||||
class TcpDnsClientSpec extends AkkaSpec with ImplicitSender {
|
||||
class TcpDnsClientSpec extends PekkoSpec with ImplicitSender {
|
||||
import TcpDnsClient._
|
||||
|
||||
"The async TCP DNS client" should {
|
||||
|
|
|
|||
|
|
@ -13,12 +13,12 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor._
|
||||
import pekko.testkit.{ AkkaSpec, TestProbe }
|
||||
import pekko.testkit.{ PekkoSpec, TestProbe }
|
||||
import pekko.testkit.WithLogCapturing
|
||||
import pekko.util.Timeout
|
||||
|
||||
@nowarn
|
||||
class AskSpec extends AkkaSpec("""
|
||||
class AskSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
""") with WithLogCapturing {
|
||||
|
|
|
|||
|
|
@ -14,7 +14,7 @@ import scala.annotation.nowarn
|
|||
import org.apache.pekko
|
||||
import pekko.actor._
|
||||
import pekko.pattern.TestActor.NormalException
|
||||
import pekko.testkit.{ filterException, AkkaSpec, ImplicitSender, TestProbe }
|
||||
import pekko.testkit.{ filterException, ImplicitSender, PekkoSpec, TestProbe }
|
||||
import pekko.testkit.WithLogCapturing
|
||||
|
||||
object TestActor {
|
||||
|
|
@ -54,7 +54,7 @@ class TestParentActor(probe: ActorRef, supervisorProps: Props) extends Actor {
|
|||
}
|
||||
}
|
||||
|
||||
class BackoffOnRestartSupervisorSpec extends AkkaSpec("""
|
||||
class BackoffOnRestartSupervisorSpec extends PekkoSpec("""
|
||||
pekko.loglevel = DEBUG
|
||||
pekko.loggers = ["org.apache.pekko.testkit.SilenceAllTestEventListener"]
|
||||
""") with WithLogCapturing with ImplicitSender {
|
||||
|
|
|
|||
|
|
@ -45,7 +45,7 @@ object BackoffSupervisorSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class BackoffSupervisorSpec extends AkkaSpec with ImplicitSender with Eventually {
|
||||
class BackoffSupervisorSpec extends PekkoSpec with ImplicitSender with Eventually {
|
||||
import BackoffSupervisorSpec._
|
||||
|
||||
def onStopOptions(props: Props = Child.props(testActor), maxNrOfRetries: Int = -1): BackoffOnStopOptions =
|
||||
|
|
|
|||
|
|
@ -11,7 +11,7 @@ import scala.concurrent.duration._
|
|||
|
||||
import org.apache.pekko.testkit._
|
||||
|
||||
class CircuitBreakerMTSpec extends AkkaSpec {
|
||||
class CircuitBreakerMTSpec extends PekkoSpec {
|
||||
implicit val ec: ExecutionContextExecutor = system.dispatcher
|
||||
"A circuit breaker being called by many threads" must {
|
||||
val callTimeout = 2.seconds.dilated
|
||||
|
|
|
|||
|
|
@ -83,7 +83,7 @@ object CircuitBreakerSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class CircuitBreakerSpec extends AkkaSpec("""
|
||||
class CircuitBreakerSpec extends PekkoSpec("""
|
||||
pekko.circuit-breaker {
|
||||
identified {
|
||||
max-failures = 1
|
||||
|
|
|
|||
|
|
@ -15,7 +15,7 @@ import pekko.actor.Actor
|
|||
import pekko.actor.ActorLogging
|
||||
import pekko.actor.Props
|
||||
import pekko.actor.Status.Failure
|
||||
import pekko.testkit.AkkaSpec
|
||||
import pekko.testkit.PekkoSpec
|
||||
import pekko.testkit.ImplicitSender
|
||||
|
||||
object CircuitBreakerStressSpec {
|
||||
|
|
@ -61,7 +61,7 @@ object CircuitBreakerStressSpec {
|
|||
}
|
||||
|
||||
// reproducer for issue #17415
|
||||
class CircuitBreakerStressSpec extends AkkaSpec with ImplicitSender {
|
||||
class CircuitBreakerStressSpec extends PekkoSpec with ImplicitSender {
|
||||
import CircuitBreakerStressSpec._
|
||||
|
||||
muteDeadLetters(classOf[AnyRef])(system)
|
||||
|
|
|
|||
|
|
@ -12,7 +12,7 @@ import language.postfixOps
|
|||
|
||||
import org.apache.pekko
|
||||
import pekko.actor.{ Actor, Props }
|
||||
import pekko.testkit.{ AkkaSpec, TestLatch }
|
||||
import pekko.testkit.{ PekkoSpec, TestLatch }
|
||||
|
||||
object PatternSpec {
|
||||
final case class Work(duration: Duration)
|
||||
|
|
@ -24,7 +24,7 @@ object PatternSpec {
|
|||
}
|
||||
}
|
||||
|
||||
class PatternSpec extends AkkaSpec {
|
||||
class PatternSpec extends PekkoSpec {
|
||||
implicit val ec: ExecutionContextExecutor = system.dispatcher
|
||||
import PatternSpec._
|
||||
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show more
Loading…
Add table
Add a link
Reference in a new issue