Package akka.persistence.typed.internal

Class Running.HandlingCommands

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.ExtensibleBehavior<T>

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

akka.persistence.typed.internal.Running.HandlingCommands

All Implemented Interfaces:

Running.WithSeqNrAccessible

Enclosing class:

Running<C,E,S>

public final class Running.HandlingCommands
extends AbstractBehavior<InternalProtocol>
implements Running.WithSeqNrAccessible

Nested Class Summary

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

Behavior.BehaviorDecorators<T>, Behavior.BehaviorDecorators$, Behavior.DeferredBehavior<T>, Behavior.DeferredBehavior$, Behavior.EmptyBehavior$, Behavior.FailedBehavior, Behavior.IgnoreBehavior$, Behavior.SameBehavior$, Behavior.StoppedBehavior<T>, Behavior.StoppedBehavior$, Behavior.UnhandledBehavior$

Constructor Summary

Constructors

Constructor	Description
HandlingCommands(Running.RunningState<S> state)

Method Summary

Modifier and Type	Method	Description
java.lang.Object	adaptEvent(E event)
Behavior<InternalProtocol>	applyEffects(java.lang.Object msg, Running.RunningState<S> state, Effect<E,S> effect, scala.collection.immutable.Seq<SideEffect<S>> sideEffects)
scala.collection.immutable.Seq<SideEffect<S>>	applyEffects$default$4()
long	currentSequenceNumber()
Behavior<InternalProtocol>	onCommand(Running.RunningState<S> state, C cmd)
Behavior<InternalProtocol>	onMessage(InternalProtocol msg)
scala.PartialFunction<Signal,Behavior<InternalProtocol>>	onSignal()	Override this method to process an incoming Signal and return the next behavior.

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

receive, receiveSignal

Methods inherited from class akka.actor.typed.Behavior

_tag, BehaviorDecorators, canonicalize, empty, existsInStack, failed, ignore, interpretMessage, interpretSignal, isAlive, isDeferred, isUnhandled, narrow, orElse, same, start, stopped, stopped, unhandled, unhandledSignal, unsafeCast, validateAsInitial

Methods inherited from class java.lang.Object

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

Constructor Detail

HandlingCommands

public HandlingCommands(Running.RunningState<S> state)

Method Detail

adaptEvent

public java.lang.Object adaptEvent(E event)

applyEffects

public Behavior<InternalProtocol> applyEffects(java.lang.Object msg,
                                               Running.RunningState<S> state,
                                               Effect<E,S> effect,
                                               scala.collection.immutable.Seq<SideEffect<S>> sideEffects)

applyEffects$default$4

public scala.collection.immutable.Seq<SideEffect<S>> applyEffects$default$4()

currentSequenceNumber

public long currentSequenceNumber()

Specified by:

currentSequenceNumber in interface Running.WithSeqNrAccessible

onCommand

public Behavior<InternalProtocol> onCommand(Running.RunningState<S> state,
                                            C cmd)

onMessage

public Behavior<InternalProtocol> onMessage(InternalProtocol msg)

Specified by:

onMessage in class AbstractBehavior<InternalProtocol>

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>

Returns:

(undocumented)