首页 > 代码库 > akka-persistence note

akka-persistence note

Recovery

默认下,一个persistent acotr在启动时会自动recover,在重启的时候回放journaled messages. 当在回放message时,被送到persistent actor的新message不会被干扰. 要等recovery完成时,新的message才会被接收到persistent actor.

默认persistent actor会被恢复到最新的状态,如果想恢复到过去的状态,使用upper squence number bounds.

override def preStart() {  self ! Recover(toSequenceNr = 457L)}

 

akka-persistence note