【发布时间】:2017-05-06 20:44:33
【问题描述】:
我们如何在 akka-persistence 中查询旧快照?
我可以看到SnapshotStore 有一个LoadSnapshot 消息,可以私下使用,但不能以其他方式调用。
snapshotter中有一个接口 -> loadSnapshot
但这给了演员一个回调,这不是我需要的。
/**
* Instructs the snapshot store to load the specified snapshot and send it via an [[SnapshotOffer]]
* to the running [[PersistentActor]].
*/
def loadSnapshot(persistenceId: String, criteria: SnapshotSelectionCriteria, toSequenceNr: Long) =
snapshotStore ! LoadSnapshot(persistenceId, criteria, toSequenceNr)
我基本上需要一种ask 快照存储的方法来给我一个我需要的快照。
有没有办法做到这一点?为什么它被明确地设为私有而不是可调用的?
【问题讨论】:
标签: scala akka snapshot akka-persistence