我正在考虑使用CQRS的Akka持久性 . 在我的写作方面,我有像这样的实体
case class Evt(data:String)
我的持久代码看起来像
persist(Evt(s"${data}"))
所有工作都在写作方面 .
我正在使用Redis journal插件 .
当我尝试读取Read端的日志条目时,它会查找WriteModel.Evt类并看到下面的错误
[akka.dispatch.Dispatcher] WriteModel.Evt java.lang.ClassNotFoundException: WriteModel.Evt
我是否适当地坚持了这个活动?
分享Write和Read / Aggregator端之间联系的最佳实践是什么?