處理阿卡持久性故障

Question

我正在用阿卡持久性構建應用程序。

我必須正確檢測並處理持久性故障。這怎麼可能？它會拋出任何持久性異常嗎？

這裏是我到現在爲止

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

...  
} 

Answer 1

當錯誤發生時將拋出akka persistence failure section的onPersistFailure

更多的信息，同時也發生錯誤時Persistence_status_handling

看看不同的處理程序