I looked at https://github.com/EventStore/EventStore.JVM. I was not able to figure out How to use it to integrate with akka persistence event store.
Let me give you some clarity on what I want to achieve.
My app is based upon approach event sourced/cqrs/DDD.
My app uses Akka Persistence with cassandra event store.
Consider I have domain model’s,
Bank object will have many customers.
Every customer will have multiple accounts.
Consider for sake of discussion I have made each Domain object as Aggregate Root using API PesistentActor. Each AR is a single writer.
Consider app is designed to receive below events,
Consider system receives events,
createBank —> to create “BankAkka”. Bank AR will receive this event.
addCustomer --> to include customer “Meee”. Customer AR will receive this event.
createAccount -->create savings account. Account AR will receive this event.
creditAccount–>200$. Account AR will receive this event.
debitAccount -->150$. Account AR will receive this event.
Each AR after receiving event will save event to event store and later handled by handler.
I want to implement a query : Give all customers in system whose balance is less then 100$.
How to integrate EventStore.JVM with event store of akka persistence. In my event store is cassandra.
-Prakhyat M M