This tutorial contains examples that illustrate a subset of Akka Persistence features.
Custom storage locations for the journal and snapshots can be defined in application.conf.
PersistentActorExample.java
is described in detail in the Event sourcing
section of the user documentation. With every application run, the ExamplePersistentActor
is recovered from
events stored in previous application runs, processes new commands, stores new events and snapshots and prints the
current persistent actor state to stdout
.
To run this example, go to the Run tab, and run the application main class
sample.persistence.PersistentActorExample
several times.
SnapshotExample.java demonstrates how persistent actors can take snapshots of application state and recover from previously stored snapshots. Snapshots are offered to persistent actors at the beginning of recovery, before any messages (younger than the snapshot) are replayed.
To run this example, go to the Run tab, and run the application main class
sample.persistence.SnapshotExample
several times. With every run, the state offered by the
most recent snapshot is printed to stdout
, followed by the updated state after sending new persistent
messages to the persistent actor.
PersistentActorFailureExample.java shows how a persistent actor can throw an exception, restart and restore the state by replaying the events.
To run this example, go to the Run tab, and run the application main class
sample.persistence.PersistentActorFailureExample
several times.
ViewExample.java demonstrates
how a view (ExampleView
) is updated with the persistent message stream of a persistent actor
(ExamplePersistentActor
). Messages sent to the persistent actor are scheduled periodically. Views also support
snapshotting to reduce recovery time.
To run this example, go to the Run tab, and run the application main class
sample.persistence.PersistentViewExample
.