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>

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.typed.internal.JournalInteractions

JournalInteractions.EventToPersist, JournalInteractions.EventToPersist$

Constructor Summary

Constructors

Constructor	Description
RequestingRecoveryPermit(BehaviorSetup<C,E,S> setup)

Method Summary

Modifier and Type	Method	Description
static <C,E,S> Behavior<InternalProtocol>	apply(BehaviorSetup<C,E,S> setup)
Behavior<InternalProtocol>	createBehavior()
void	onRequestingRecoveryPermit(ActorContext<?> context)
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, onWriteInitiated, onWritesInitiated, 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 interface JournalInteractions<C,E,S>

Specified by:

setup in interface SnapshotInteractions<C,E,S>

Specified by:

setup in interface StashManagement<C,E,S>

createBehavior

public Behavior<InternalProtocol> createBehavior()

onRequestingRecoveryPermit

public void onRequestingRecoveryPermit(ActorContext<?> context)