Обработка сбоев персистентности akka

Я создаю приложение с постоянством 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))
        }

...     
}

person Sreenath Chothar    schedule 25.09.2015    source источник


Ответы (1)


При возникновении ошибки выдается onPersistFailure

Дополнительные сведения см. в разделе об ошибках сохраняемости akka, а также просмотрите различные обработчики при возникновении ошибки Persistence_status_handling

person Diego Alvarez    schedule 25.09.2015