Package akka.actor.typed.scaladsl

Class AbstractBehavior<T>

java.lang.Object

akka.actor.typed.Behavior<T>

akka.actor.typed.ExtensibleBehavior<T>

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

Direct Known Subclasses:

GroupRouterImpl, GuardianStartupBehavior, PoolRouterImpl, ReplayingEvents, Running.HandlingCommands, Running.PersistingEvents

public abstract class AbstractBehavior<T>
extends ExtensibleBehavior<T>

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

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
AbstractBehavior()

Method Summary

Modifier and Type	Method	Description
abstract Behavior<T>	onMessage(T msg)
scala.PartialFunction<Signal,Behavior<T>>	onSignal()	Override this method to process an incoming Signal and return the next behavior.
Behavior<T>	receive(TypedActorContext<T> ctx, T msg)
Behavior<T>	receiveSignal(TypedActorContext<T> ctx, Signal msg)	Process an incoming Signal and return the next behavior.

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

AbstractBehavior

public AbstractBehavior()

Method Detail

onMessage

public abstract Behavior<T> onMessage(T msg)
                               throws java.lang.Exception

Throws:

java.lang.Exception

onSignal

public scala.PartialFunction<Signal,Behavior<T>> onSignal()
                                                         throws java.lang.Exception

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.

Returns:

(undocumented)

Throws:

java.lang.Exception

receive

public final Behavior<T> receive(TypedActorContext<T> ctx,
                                 T msg)
                          throws java.lang.Exception

Specified by:

receive in class ExtensibleBehavior<T>

Throws:

java.lang.Exception

receiveSignal

public final Behavior<T> receiveSignal(TypedActorContext<T> ctx,
                                       Signal msg)
                                throws java.lang.Exception

Description copied from class: ExtensibleBehavior

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 same designates to reuse the current Behavior * returning unhandled keeps the same Behavior and signals that the message was not yet handled

Code calling this method should use Behavior$ canonicalize to replace the special objects with real Behaviors.

Specified by:

receiveSignal in class ExtensibleBehavior<T>

Parameters:

ctx - (undocumented)

msg - (undocumented)

Returns:

(undocumented)

Throws:

java.lang.Exception