raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fix #16364 - Doc - Persistent actor - clarification of the recovery customization

Browse source
This commit is contained in:
Marek Prochera 2014-11-21 16:59:21 +01:00
parent f2487d73f4
commit b43f3639d6
4 changed files with 44 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

19
akka-docs/rst/java/code/docs/persistence/PersistenceDocTest.java
View file

@ -71,8 +71,8 @@ public class PersistenceDocTest {
//#usage
processor = getContext().actorOf(Props.create(MyProcessor.class), "myProcessor");
processor.tell(Persistent.create("foo"), null);
processor.tell("bar", null);
processor.tell(Persistent.create("foo"), getSelf());
processor.tell("bar", getSelf());
//#usage
}
@ -82,7 +82,7 @@ public class PersistenceDocTest {
private void recover() {
//#recover-explicit
processor.tell(Recover.create(), null);
processor.tell(Recover.create(), getSelf());
//#recover-explicit
}
}
@ -105,7 +105,7 @@ public class PersistenceDocTest {
//#recover-on-start-custom
@Override
public void preStart() {
getSelf().tell(Recover.create(457L), null);
getSelf().tell(Recover.create(457L), getSelf());
}
//#recover-on-start-custom
}
@ -166,6 +166,15 @@ public class PersistenceDocTest {
//#recovery-completed
}
};
static Object fullyDisabledRecoveyExample = new Object() {
abstract class MyProcessor1 extends UntypedPersistentActor {
//#recover-fully-disabled
@Override
public void preStart() { getSelf().tell(Recover.create(0L), getSelf()); }
//#recover-fully-disabled
}
};
static Object atLeastOnceExample = new Object() {
//#at-least-once-example
@ -563,7 +572,7 @@ public class PersistenceDocTest {
final Procedure<String> replyToSender = new Procedure<String>() {
@Override
public void apply(String event) throws Exception {
sender().tell(event, self());
sender().tell(event, getSelf());
}
};