我的应用程序需要记录演员处理的所有消息,minSequenceNr
并maxSequenceNr
有时在之间重播消息。
akka-persistence 对这个用例有用吗?如果是,如何强制重播日志中的消息?我可以Persistence(actorSystem).journalFor("x")
用来获取期刊的 ActorRef 但我不能发送JournalProtocol.ReplayMessages
给它,因为它JournalProtocol
是私有的akka.persistence
。