Package akka.persistence.typed.internal

Class Running<C,E,S>

java.lang.Object

akka.persistence.typed.internal.Running<C,E,S>

All Implemented Interfaces:

JournalInteractions<C,E,S>, SnapshotInteractions<C,E,S>, StashManagement<C,E,S>

public final class Running<C,E,S>
extends java.lang.Object
implements JournalInteractions<C,E,S>, SnapshotInteractions<C,E,S>, StashManagement<C,E,S>

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	Running.HandlingCommands
class	Running.PersistingEvents	INTERNAL API
class	Running.PersistingEvents$
static class	Running.RunningState<State>
static class	Running.RunningState$
class	Running.StoringSnapshot	INTERNAL API
static interface	Running.WithSeqNrAccessible

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
static <C,E,S> Behavior<InternalProtocol>	apply(BehaviorSetup<C,E,S> setup, Running.RunningState<S> state)
Behavior<InternalProtocol>	applySideEffect(SideEffect<S> effect, Running.RunningState<S> state, Behavior<InternalProtocol> behavior)
Behavior<InternalProtocol>	applySideEffects(scala.collection.immutable.Seq<SideEffect<S>> effects, Running.RunningState<S> state)
Behavior<InternalProtocol>	onDeleteEventsJournalResponse(JournalProtocol.Response response, S state)	Handle journal responses for non-persist events workloads.
Behavior<InternalProtocol>	onDeleteSnapshotResponse(SnapshotProtocol.Response response, S state)	Handle snapshot responses for non-persist events workloads.
void	onWriteDone(ActorContext<?> ctx, PersistentRepr event)
void	onWriteFailed(ActorContext<?> ctx, java.lang.Throwable reason, PersistentRepr event)
void	onWriteRejected(ActorContext<?> ctx, java.lang.Throwable reason, PersistentRepr event)
void	onWriteSuccess(ActorContext<?> ctx, PersistentRepr event)
Behavior<InternalProtocol>	persistingEvents(Running.RunningState<S> state, Running.RunningState<S> visibleState, int numberOfEvents, BehaviorSetup.SnapshotAfterPersist shouldSnapshotAfterPersist, scala.collection.immutable.Seq<SideEffect<S>> sideEffects)
Running.PersistingEvents$	PersistingEvents()	Accessor for nested Scala object
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

Running

public Running(BehaviorSetup<C,E,S> setup)

Method Detail

apply

public static <C,E,S> Behavior<InternalProtocol> apply(BehaviorSetup<C,E,S> setup,
                                                                   Running.RunningState<S> state)

PersistingEvents

public Running.PersistingEvents$ PersistingEvents()

Accessor for nested Scala object

Returns:

(undocumented)

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>

persistingEvents

public Behavior<InternalProtocol> persistingEvents(Running.RunningState<S> state,
                                                   Running.RunningState<S> visibleState,
                                                   int numberOfEvents,
                                                   BehaviorSetup.SnapshotAfterPersist shouldSnapshotAfterPersist,
                                                   scala.collection.immutable.Seq<SideEffect<S>> sideEffects)

applySideEffects

public Behavior<InternalProtocol> applySideEffects(scala.collection.immutable.Seq<SideEffect<S>> effects,
                                                   Running.RunningState<S> state)

applySideEffect

public Behavior<InternalProtocol> applySideEffect(SideEffect<S> effect,
                                                  Running.RunningState<S> state,
                                                  Behavior<InternalProtocol> behavior)

onDeleteEventsJournalResponse

public Behavior<InternalProtocol> onDeleteEventsJournalResponse(JournalProtocol.Response response,
                                                                S state)

Handle journal responses for non-persist events workloads. These are performed in the background and may happen in all phases.

onDeleteSnapshotResponse

public Behavior<InternalProtocol> onDeleteSnapshotResponse(SnapshotProtocol.Response response,
                                                           S state)

Handle snapshot responses for non-persist events workloads. These are performed in the background and may happen in all phases.

onWriteFailed

public void onWriteFailed(ActorContext<?> ctx,
                          java.lang.Throwable reason,
                          PersistentRepr event)

onWriteRejected

public void onWriteRejected(ActorContext<?> ctx,
                            java.lang.Throwable reason,
                            PersistentRepr event)

onWriteSuccess

public void onWriteSuccess(ActorContext<?> ctx,
                           PersistentRepr event)

onWriteDone

public void onWriteDone(ActorContext<?> ctx,
                        PersistentRepr event)