Package akka.persistence.typed.internal

Class Running.PersistingEvents

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.ExtensibleBehavior<T>

akka.actor.typed.scaladsl.AbstractBehavior<InternalProtocol>

akka.persistence.typed.internal.Running.PersistingEvents

All Implemented Interfaces:

Running.WithSeqNrAccessible

Enclosing class:

Running<C,E,S>

public class Running.PersistingEvents
extends AbstractBehavior<InternalProtocol>
implements Running.WithSeqNrAccessible

INTERNAL API

Nested Class Summary

Nested classes/interfaces inherited from class akka.actor.typed.Behavior

Behavior.BehaviorDecorators<Inner>, Behavior.BehaviorDecorators$

Constructor Summary

Constructors

Constructor	Description
PersistingEvents(Running.RunningState<S> state, Running.RunningState<S> visibleState, int numberOfEvents, BehaviorSetup.SnapshotAfterPersist shouldSnapshotAfterPersist, boolean shouldPublish, scala.collection.immutable.Seq<SideEffect<S>> sideEffects, long persistStartTime)

Method Summary

Modifier and Type	Method	Description
long	currentSequenceNumber()
Behavior<InternalProtocol>	onCommand(InternalProtocol.IncomingCommand<C> cmd)
Running.PersistingEvents	onGetSeenSequenceNr(EventSourcedBehaviorImpl.GetSeenSequenceNr get)
Behavior<InternalProtocol>	onJournalResponse(JournalProtocol.Response response)
Behavior<InternalProtocol>	onMessage(InternalProtocol msg)	Implement this method to process an incoming message and return the next behavior.
Behavior<InternalProtocol>	onPublishedEvent(PublishedEventImpl event)
Behavior<InternalProtocol>	onReplicatedEvent(InternalProtocol.ReplicatedEventEnvelope<E> event)
scala.PartialFunction<Signal,Behavior<InternalProtocol>>	onSignal()	Override this method to process an incoming Signal and return the next behavior.
scala.collection.immutable.Seq<SideEffect<S>>	sideEffects()
void	sideEffects_$eq(scala.collection.immutable.Seq<SideEffect<S>> x$1)
Running.RunningState<S>	state()
void	state_$eq(Running.RunningState<S> x$1)
Running.RunningState<S>	visibleState()
void	visibleState_$eq(Running.RunningState<S> x$1)

Methods inherited from class akka.actor.typed.scaladsl.AbstractBehavior

context, receive, receiveSignal

Methods inherited from class akka.actor.typed.Behavior

_tag, BehaviorDecorators, canonicalize, existsInStack, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, start, unsafeCast, validateAsInitial

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PersistingEvents

public PersistingEvents(Running.RunningState<S> state,
                        Running.RunningState<S> visibleState,
                        int numberOfEvents,
                        BehaviorSetup.SnapshotAfterPersist shouldSnapshotAfterPersist,
                        boolean shouldPublish,
                        scala.collection.immutable.Seq<SideEffect<S>> sideEffects,
                        long persistStartTime)

Method Detail

state

public Running.RunningState<S> state()

state_$eq

public void state_$eq(Running.RunningState<S> x$1)

visibleState

public Running.RunningState<S> visibleState()

visibleState_$eq

public void visibleState_$eq(Running.RunningState<S> x$1)

sideEffects

public scala.collection.immutable.Seq<SideEffect<S>> sideEffects()

sideEffects_$eq

public void sideEffects_$eq(scala.collection.immutable.Seq<SideEffect<S>> x$1)

onMessage

public Behavior<InternalProtocol> onMessage(InternalProtocol msg)

Description copied from class: AbstractBehavior

Implement this method to process an incoming message and return the next behavior.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

• returning stopped will terminate this Behavior
• returning this or same designates to reuse the current Behavior
• returning unhandled keeps the same Behavior and signals that the message was not yet handled

Specified by:

onMessage in class AbstractBehavior<InternalProtocol>

onCommand

public Behavior<InternalProtocol> onCommand(InternalProtocol.IncomingCommand<C> cmd)

onGetSeenSequenceNr

public Running.PersistingEvents onGetSeenSequenceNr(EventSourcedBehaviorImpl.GetSeenSequenceNr get)

onReplicatedEvent

public Behavior<InternalProtocol> onReplicatedEvent(InternalProtocol.ReplicatedEventEnvelope<E> event)

onPublishedEvent

public Behavior<InternalProtocol> onPublishedEvent(PublishedEventImpl event)

onJournalResponse

public final Behavior<InternalProtocol> onJournalResponse(JournalProtocol.Response response)

onSignal

public scala.PartialFunction<Signal,Behavior<InternalProtocol>> onSignal()

Description copied from class: AbstractBehavior

Override this method to process an incoming Signal and return the next behavior. This means that all lifecycle hooks, ReceiveTimeout, Terminated and Failed messages can initiate a behavior change.

The returned behavior can in addition to normal behaviors be one of the canned special objects:

* returning stopped will terminate this Behavior * returning this or same designates to reuse the current Behavior * returning unhandled keeps the same Behavior and signals that the message was not yet handled

By default, partial function is empty and does not handle any signals.

Overrides:

onSignal in class AbstractBehavior<InternalProtocol>

currentSequenceNumber

public long currentSequenceNumber()

Specified by:

currentSequenceNumber in interface Running.WithSeqNrAccessible