Package akka.persistence.typed.internal
Class RequestingRecoveryPermit<C,E,S>
- java.lang.Object
-
- akka.persistence.typed.internal.RequestingRecoveryPermit<C,E,S>
-
- All Implemented Interfaces:
JournalInteractions<C,E,S>
,SnapshotInteractions<C,E,S>
,StashManagement<C,E,S>
public class RequestingRecoveryPermit<C,E,S> extends java.lang.Object implements StashManagement<C,E,S>, JournalInteractions<C,E,S>, SnapshotInteractions<C,E,S>
-
-
Constructor Summary
Constructors Constructor Description RequestingRecoveryPermit(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)
Behavior<InternalProtocol>
createBehavior()
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
-
RequestingRecoveryPermit
public RequestingRecoveryPermit(BehaviorSetup<C,E,S> setup)
-
-
Method Detail
-
apply
public static <C,E,S> Behavior<InternalProtocol> apply(BehaviorSetup<C,E,S> setup)
-
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()
-
-