从持久性 Akka 日志中清除消息

Clearing Messages From a persistent Akka journal

我正在测试一个持久的 Akka actor。为此,我正在使用内存持久性。测试开始,我看到参与者正在恢复持久消息。我尝试以下操作:

我向演员发送了一条消息,使其触发 deleteMessages(LastMessage)。我希望这条消息会导致日志被清除。 参与者似乎没有处理此消息,因为正在恢复的消息之前 运行 进入异常。因此它抛出异常并且不继续处理消息。

如何清除持久化的日志?

我还认为内存持久化不会从日志中恢复以前的测试消息

为了在测试中使用更强大的内存日志实现,我建议使用 https://github.com/dnvriend/akka-persistence-inmemory

它支持清除日志(和快照):https://github.com/dnvriend/akka-persistence-inmemory#clearing-journal-and-snapshot-messages,以及ReadJournal