从持久性 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
。
我正在测试一个持久的 Akka actor。为此,我正在使用内存持久性。测试开始,我看到参与者正在恢复持久消息。我尝试以下操作:
我向演员发送了一条消息,使其触发 deleteMessages(LastMessage)
。我希望这条消息会导致日志被清除。
参与者似乎没有处理此消息,因为正在恢复的消息之前 运行 进入异常。因此它抛出异常并且不继续处理消息。
如何清除持久化的日志?
我还认为内存持久化不会从日志中恢复以前的测试消息
为了在测试中使用更强大的内存日志实现,我建议使用 https://github.com/dnvriend/akka-persistence-inmemory。
它支持清除日志(和快照):https://github.com/dnvriend/akka-persistence-inmemory#clearing-journal-and-snapshot-messages,以及ReadJournal
。