Package akka.persistence.typed.internal

Interface JournalInteractions<C,E,S>

All Known Implementing Classes:

ReplayingEvents, ReplayingSnapshot, RequestingRecoveryPermit, Running

public interface JournalInteractions<C,E,S>

Intended to be used in .onSignal(returnPermitOnStop) by behaviors

Method Summary

Modifier and Type	Method	Description
void	internalDeleteEvents(long lastSequenceNr, long toSequenceNr)	On SaveSnapshotSuccess, if SnapshotCountRetentionCriteria.deleteEventsOnSnapshot is enabled, old messages are deleted based on SnapshotCountRetentionCriteria.snapshotEveryNEvents before old snapshots are deleted.
Running.RunningState<S>	internalPersist(Running.RunningState<S> state, java.lang.Object event)
Running.RunningState<S>	internalPersistAll(scala.collection.immutable.Seq<java.lang.Object> events, Running.RunningState<S> state)
void	replayEvents(long fromSeqNr, long toSeqNr)
void	requestRecoveryPermit()
scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>>	returnPermitOnStop()	Intended to be used in .onSignal(returnPermitOnStop) by behaviors
BehaviorSetup<C,E,S>	setup()
void	tryReturnRecoveryPermit(java.lang.String reason)	Mutates setup, by setting the `holdingRecoveryPermit` to false

Method Detail

internalDeleteEvents

void internalDeleteEvents(long lastSequenceNr,
                          long toSequenceNr)

On SaveSnapshotSuccess, if SnapshotCountRetentionCriteria.deleteEventsOnSnapshot is enabled, old messages are deleted based on SnapshotCountRetentionCriteria.snapshotEveryNEvents before old snapshots are deleted.

Parameters:

lastSequenceNr - (undocumented)

toSequenceNr - (undocumented)

internalPersist

Running.RunningState<S> internalPersist(Running.RunningState<S> state,
                                        java.lang.Object event)

internalPersistAll

Running.RunningState<S> internalPersistAll(scala.collection.immutable.Seq<java.lang.Object> events,
                                           Running.RunningState<S> state)

replayEvents

void replayEvents(long fromSeqNr,
                  long toSeqNr)

requestRecoveryPermit

void requestRecoveryPermit()

returnPermitOnStop

scala.PartialFunction<scala.Tuple2<ActorContext<InternalProtocol>,Signal>,Behavior<InternalProtocol>> returnPermitOnStop()

Intended to be used in .onSignal(returnPermitOnStop) by behaviors

setup

BehaviorSetup<C,E,S> setup()

tryReturnRecoveryPermit

void tryReturnRecoveryPermit(java.lang.String reason)

Mutates setup, by setting the `holdingRecoveryPermit` to false