diff --git a/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/BasicPersistentBehaviorTest.java b/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/BasicPersistentBehaviorTest.java index de828fe66e..9b68bb5c60 100644 --- a/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/BasicPersistentBehaviorTest.java +++ b/akka-persistence-typed/src/test/java/jdocs/akka/persistence/typed/BasicPersistentBehaviorTest.java @@ -46,8 +46,8 @@ public class BasicPersistentBehaviorTest { public static class State {} - public static Behavior create() { - return new MyPersistentBehavior(PersistenceId.ofUniqueId("pid")); + public static Behavior create(PersistenceId persistenceId) { + return new MyPersistentBehavior(persistenceId); } private MyPersistentBehavior(PersistenceId persistenceId) { diff --git a/akka-persistence-typed/src/test/scala/docs/akka/persistence/typed/BasicPersistentBehaviorCompileOnly.scala b/akka-persistence-typed/src/test/scala/docs/akka/persistence/typed/BasicPersistentBehaviorCompileOnly.scala index f0c5c12e50..1a49ec33f4 100644 --- a/akka-persistence-typed/src/test/scala/docs/akka/persistence/typed/BasicPersistentBehaviorCompileOnly.scala +++ b/akka-persistence-typed/src/test/scala/docs/akka/persistence/typed/BasicPersistentBehaviorCompileOnly.scala @@ -108,10 +108,10 @@ object BasicPersistentBehaviorCompileOnly { import MyPersistentBehavior._ object RecoveryBehavior { - def apply(): Behavior[Command] = + def apply(persistenceId: PersistenceId): Behavior[Command] = //#recovery EventSourcedBehavior[Command, Event, State]( - persistenceId = PersistenceId.ofUniqueId("abc"), + persistenceId = persistenceId, emptyState = State(), commandHandler = (state, cmd) => throw new NotImplementedError("TODO: process the command & return an Effect"), eventHandler = (state, evt) => throw new NotImplementedError("TODO: process the event return the next state"))