diff --git a/akka-typed-tests/src/test/java/akka/typed/javadsl/MonitoringTest.java b/akka-typed-tests/src/test/java/akka/typed/javadsl/MonitoringTest.java index f0f9eb001a..eca93bd4a8 100644 --- a/akka-typed-tests/src/test/java/akka/typed/javadsl/MonitoringTest.java +++ b/akka-typed-tests/src/test/java/akka/typed/javadsl/MonitoringTest.java @@ -31,13 +31,13 @@ public class MonitoringTest extends JUnitSuite { // final FiniteDuration fiveSeconds = FiniteDuration.create(5, TimeUnit.SECONDS); final Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS)); - final Behavior exitingActor = stateful((ctx, msg) -> { + final Behavior exitingActor = immutable((ctx, msg) -> { System.out.println("Stopping!"); return stopped(); }); private Behavior> waitingForTermination(ActorRef replyWhenTerminated) { - return stateful( + return immutable( (ctx, msg) -> unhandled(), (ctx, sig) -> { if (sig instanceof Terminated) { @@ -51,7 +51,7 @@ public class MonitoringTest extends JUnitSuite { @Test public void shouldWatchTerminatingActor() throws Exception { - Behavior> root = stateful((ctx, msg) -> { + Behavior> root = immutable((ctx, msg) -> { ActorRef watched = ctx.spawn(exitingActor, "exitingActor"); ctx.watch(watched); watched.tell(new Stop());