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
orsame
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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description abstract Behavior<T>
onMessage(T msg)
scala.PartialFunction<Signal,Behavior<T>>
onSignal()
Override this method to process an incomingSignal
and return the next behavior.Behavior<T>
receive(TypedActorContext<T> ctx, T msg)
Behavior<T>
receiveSignal(TypedActorContext<T> ctx, Signal msg)
Process an incomingSignal
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
-
-
-
-
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 incomingSignal
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 * returningthis
orsame
designates to reuse the current Behavior * returningunhandled
keeps the same Behavior and signals that the message was not yet handledBy 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 classExtensibleBehavior<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 incomingSignal
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 * returningsame
designates to reuse the current Behavior * returningunhandled
keeps the same Behavior and signals that the message was not yet handledCode calling this method should use
Behavior$
canonicalize
to replace the special objects with real Behaviors.- Specified by:
receiveSignal
in classExtensibleBehavior<T>
- Parameters:
ctx
- (undocumented)msg
- (undocumented)- Returns:
- (undocumented)
- Throws:
java.lang.Exception
-
-