Package akka.persistence.typed.internal
Class ReplayingSnapshot<C,E,S>
- java.lang.Object
-
- akka.persistence.typed.internal.ReplayingSnapshot<C,E,S>
-
- All Implemented Interfaces:
JournalInteractions<C,E,S>
,SnapshotInteractions<C,E,S>
,StashManagement<C,E,S>
public class ReplayingSnapshot<C,E,S> extends java.lang.Object implements JournalInteractions<C,E,S>, SnapshotInteractions<C,E,S>, StashManagement<C,E,S>
Called whenever a message replay fails. By default it logs the error.The actor is always stopped after this method has been invoked.
param: cause failure cause.
-
-
Constructor Summary
Constructors Constructor Description ReplayingSnapshot(BehaviorSetup<C,E,S> setup)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <C,E,S>
Behavior<InternalProtocol>apply(BehaviorSetup<C,E,S> setup, boolean receivedPoisonPill)
Behavior<InternalProtocol>
createBehavior(boolean receivedPoisonPillInPreviousPhase)
Behavior<InternalProtocol>
onCommand(InternalProtocol.IncomingCommand<C> cmd)
Behavior<InternalProtocol>
onJournalResponse(JournalProtocol.Response response)
Behavior<InternalProtocol>
onSnapshotterResponse(SnapshotProtocol.Response response, boolean receivedPoisonPill)
BehaviorSetup<C,E,S>
setup()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.persistence.typed.internal.JournalInteractions
internalDeleteEvents, internalPersist, internalPersistAll, replayEvents, requestRecoveryPermit, returnPermitOnStop, tryReturnRecoveryPermit
-
Methods inherited from interface akka.persistence.typed.internal.SnapshotInteractions
internalDeleteSnapshots, internalSaveSnapshot, loadSnapshot
-
Methods inherited from interface akka.persistence.typed.internal.StashManagement
context, isInternalStashEmpty, isUnstashAllInProgress, logStashMessage, logUnstashAll, logUnstashMessage, stash, stashInternal, stashState, stashUser, tryUnstashOne, unstashAll
-
-
-
-
Constructor Detail
-
ReplayingSnapshot
public ReplayingSnapshot(BehaviorSetup<C,E,S> setup)
-
-
Method Detail
-
apply
public static <C,E,S> Behavior<InternalProtocol> apply(BehaviorSetup<C,E,S> setup, boolean receivedPoisonPill)
-
setup
public BehaviorSetup<C,E,S> setup()
- Specified by:
setup
in interfaceJournalInteractions<C,E,S>
- Specified by:
setup
in interfaceSnapshotInteractions<C,E,S>
- Specified by:
setup
in interfaceStashManagement<C,E,S>
-
createBehavior
public Behavior<InternalProtocol> createBehavior(boolean receivedPoisonPillInPreviousPhase)
-
onCommand
public Behavior<InternalProtocol> onCommand(InternalProtocol.IncomingCommand<C> cmd)
-
onJournalResponse
public Behavior<InternalProtocol> onJournalResponse(JournalProtocol.Response response)
-
onSnapshotterResponse
public Behavior<InternalProtocol> onSnapshotterResponse(SnapshotProtocol.Response response, boolean receivedPoisonPill)
-
-