【问题标题】:Handling akka persistence failures处理 akka 持久性失败
【发布时间】:2015-09-25 04:48:51
【问题描述】:

我正在使用 Akka 持久性构建一个应用程序。

我必须正确检测和处理持久性故障。这怎么可能?它会抛出任何持久性异常吗?

这是我到目前为止所拥有的

override def receiveRecover: Receive = {
...
}
override def receiveCommand: Receive = {
case WorkIsDone(workerId, workId, result) =>
persist(WorkDone(workId, result)) { event =>
        workData = workData.updated(WorkDone(workId, result))
        }

...     
}

【问题讨论】:

    标签: scala akka akka-persistence


    【解决方案1】:

    发生错误时会抛出onPersistFailure

    有关akka persistence failure section 的更多信息,还可以查看发生错误时的不同处理程序Persistence_status_handling

    【讨论】:

      猜你喜欢
      • 2019-02-10
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2015-11-27
      • 1970-01-01
      • 2011-09-15
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多