Akka Persistence R2DBC
Unlike the other
AsyncWriteJournal calls, the
asyncReplayMessages one is not protected by a circuit-breaker, for a good reason:
This call is NOT protected with a circuit-breaker because it may take long time to replay all events. The plugin implementation itself must protect against an unresponsive backend store and make sure that the returned Future is completed with success or failure within reasonable time. It is not allowed to ignore completing the future.
The plugin guarantees that the Future is completed by imposing a time limit on the SQL stream's completion. You can configure the timeout with the
replay-messages-timeout parameter, the default value is
10s (in line with the circuit breaker settings).
Atomic Projectionsgives you the ability to persist an event and run projections for a "local" read-side in an atomic transaction.
The goal of the extension is to allow you to enjoy the benefits of CQRS and Event Sourcing without incurring the costs of running a more complex infrastructure for those cases when you really don't have to.
Contributions via GitHub pull requests are gladly accepted from their original author. Along with any pull requests, please state that the contribution is your original work and that you license the work to the project under the project’s open source license. Whether you state this explicitly, by submitting any copyrighted material via pull request, email, or other means you agree to license the material under the project’s open source license and warrant that you have the legal authority to do so.
This project is licensed under the Apache 2.0 license.