Skip to content

Latest commit

 

History

History
23 lines (18 loc) · 831 Bytes

README.md

File metadata and controls

23 lines (18 loc) · 831 Bytes

ReactiveCQRS

CQRS framework implementation leveraging Scala and Akka framework, for building reactive distributed applications.

it uses Default singleton ScalikeJDBC connection pool, so it has to be initialized first

TODO

  • Asunchronous command handlers- Pass execution context to command handlers?
  • Backpressure for projection rebuild
  • Externalize datastore
  • Non persistent projections

TODO

  • Projection rebuild
  • Event bus database writes optimization - aggregate update in chunks
  • Handle OptimisticLockingFailed
  • Common transaction for document stores
  • Caching document store - to improve performance of projection rebuilding
  • document store based on scalikejdbc - to improve logging of queries
  • verify and optimize db indieces
  • clock injected to framework
  • Query for events and aggregate state