Akka-persistence-inmemory is a plugin for akka-persistence that stores journal and snapshot messages memory, which is very useful when testing persistent actors, persistent FSM and akka cluster
It would be cool if we there was the JavaDsl implementation for the read journal. I prepared it for the 1.1.6 version because we ware currently on AKKA 2.4.1 but I could also do it for the current version and create a pull request.
It would be cool if we there was the JavaDsl implementation for the read journal. I prepared it for the 1.1.6 version because we ware currently on AKKA 2.4.1 but I could also do it for the current version and create a pull request.
I would suggest to simply do it like the MongoDB AKKA persistence plugin: https://github.com/scullxbones/akka-persistence-mongo/blob/master/common/src/main/scala/akka/contrib/persistence/mongodb/MongoReadJournal.scala
I am also not sure how to test this, any ideas about that without a lot of duplicated test code?