akka.persistence
Interface Recovery.State

Enclosing interface:
Recovery

public private static interface Recovery.State

INTERNAL API.

Recovery state.


Method Summary
 void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object message)
           
 void process(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object message)
           
 void processPersistent(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, Persistent persistent)
           
 void recordFailure(java.lang.Throwable cause)
           
 void updateLastSequenceNr(long value)
           
 void updateLastSequenceNr(Persistent persistent)
           
 void withCurrentPersistent(Persistent persistent, scala.Function1<Persistent,scala.runtime.BoxedUnit> body)
           
 

Method Detail

aroundReceive

void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                   java.lang.Object message)

process

void process(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
             java.lang.Object message)

processPersistent

void processPersistent(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                       Persistent persistent)

updateLastSequenceNr

void updateLastSequenceNr(Persistent persistent)

updateLastSequenceNr

void updateLastSequenceNr(long value)

withCurrentPersistent

void withCurrentPersistent(Persistent persistent,
                           scala.Function1<Persistent,scala.runtime.BoxedUnit> body)

recordFailure

void recordFailure(java.lang.Throwable cause)