This example illustrates event sourcing with Apache Pekko Persistence.
Study the source code of the ShoppingCart.scala. A few things to note:
- The actor is implemented with the
- It defines
- Commands define
replyTo: ActorRefto send a confirmation when the event has been successfully persisted
Stateis only updated in the event handler
withRetentionto enable snapshotting
onPersistFailuredefines restarts with backoff in case of failures
Tests are defined in ShoppingCartSpec.scala. To run the tests, enter:
ShoppingCart application is expanded further in the
pekko-sample-cqrs-scala sample. In that sample the events are tagged to be consumed by even processors to build other representations from the events, or publish the events to other services.