diff --git a/actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/MailboxDocTest.java b/actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/MailboxDocTest.java index 28d0684f3aa..9d6b64c1e8e 100644 --- a/actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/MailboxDocTest.java +++ b/actor-typed-tests/src/test/java/jdocs/org/apache/pekko/typed/MailboxDocTest.java @@ -19,6 +19,7 @@ import org.apache.pekko.actor.testkit.typed.javadsl.TestProbe; import org.apache.pekko.actor.typed.ActorRef; import org.apache.pekko.actor.typed.Behavior; +import org.apache.pekko.actor.typed.Dispatchers; import org.apache.pekko.actor.typed.MailboxSelector; import org.apache.pekko.actor.typed.javadsl.Behaviors; import com.typesafe.config.ConfigFactory; @@ -78,7 +79,7 @@ public void startSomeActorsWithMailboxSelectorInteroperability() { childBehavior, "from-config-mailbox-child", MailboxSelector.fromConfig("my-app.my-special-mailbox") - .withMailboxFromConfig("your-dispatcher")); + .withDispatcherFromConfig(Dispatchers.DefaultDispatcherId())); // #interoperability-with-dispatcher testProbe.ref().tell(Done.getInstance()); diff --git a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/DispatchersDocSpec.scala b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/DispatchersDocSpec.scala index 67141690eb0..1ac77f8e99c 100644 --- a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/DispatchersDocSpec.scala +++ b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/DispatchersDocSpec.scala @@ -40,6 +40,9 @@ object DispatchersDocSpec { throughput = 1 } //#config + your-mailbox { + mailbox-type = "org.apache.pekko.dispatch.SingleConsumerOnlyUnboundedMailbox" + } """.stripMargin) case class WhichDispatcher(replyTo: ActorRef[Dispatcher]) @@ -71,13 +74,13 @@ object DispatchersDocSpec { context.spawn(yourBehavior, "DefaultDispatcher") context.spawn(yourBehavior, "ExplicitDefaultDispatcher", - DispatcherSelector.default().withMailboxFromConfig("my-app.my-special-mailbox")) + DispatcherSelector.default().withMailboxFromConfig("your-mailbox")) context.spawn(yourBehavior, "BlockingDispatcher", - DispatcherSelector.blocking().withMailboxFromConfig("my-app.my-special-mailbox")) + DispatcherSelector.blocking().withMailboxFromConfig("your-mailbox")) context.spawn(yourBehavior, "ParentDispatcher", - DispatcherSelector.sameAsParent().withMailboxFromConfig("my-app.my-special-mailbox")) + DispatcherSelector.sameAsParent().withMailboxFromConfig("your-mailbox")) context.spawn(yourBehavior, "DispatcherFromConfig", - DispatcherSelector.fromConfig("your-dispatcher").withMailboxFromConfig("my-app.my-special-mailbox")) + DispatcherSelector.fromConfig("your-dispatcher").withMailboxFromConfig("your-mailbox")) // #interoperability-with-mailbox Behaviors.same diff --git a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/MailboxDocSpec.scala b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/MailboxDocSpec.scala index 935b72a057b..37763181e63 100644 --- a/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/MailboxDocSpec.scala +++ b/actor-typed-tests/src/test/scala/docs/org/apache/pekko/typed/MailboxDocSpec.scala @@ -21,11 +21,12 @@ import pekko.actor.typed.Behavior import pekko.actor.typed.MailboxSelector import pekko.actor.typed.scaladsl.Behaviors import com.typesafe.config.ConfigFactory +import org.apache.pekko.actor.typed.Dispatchers import org.scalatest.wordspec.AnyWordSpecLike class MailboxDocSpec extends ScalaTestWithActorTestKit( - ConfigFactory.load("mailbox-config-sample.conf").withFallback(DispatchersDocSpec.config)) + ConfigFactory.load("mailbox-config-sample.conf")) with AnyWordSpecLike with LogCapturing { @@ -58,7 +59,8 @@ class MailboxDocSpec context.spawn(childBehavior, "bounded-mailbox-child", MailboxSelector.bounded(100).withDispatcherDefault) val props = - MailboxSelector.fromConfig("my-app.my-special-mailbox").withDispatcherFromConfig("your-dispatcher") + MailboxSelector.fromConfig("my-app.my-special-mailbox").withDispatcherFromConfig( + Dispatchers.DefaultDispatcherId) context.spawn(childBehavior, "from-config-mailbox-child", props) // #interoperability-with-dispatcher