Skip to content
This repository has been archived by the owner on Oct 26, 2021. It is now read-only.

Files

Latest commit

1b36cb6 · Apr 8, 2017

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