Package akka.actor.typed.internal

Class SimpleSupervisor<T,Thr extends java.lang.Throwable>

java.lang.Object

akka.actor.typed.BehaviorInterceptor<java.lang.Object,I>

akka.actor.typed.internal.AbstractSupervisor<T,Thr>

akka.actor.typed.internal.SimpleSupervisor<T,Thr>

Direct Known Subclasses:

ResumeSupervisor, StopSupervisor

public abstract class SimpleSupervisor<T,Thr extends java.lang.Throwable>
extends AbstractSupervisor<T,Thr>

For cases where O == I for BehaviorInterceptor.

Nested Class Summary

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

BehaviorInterceptor.PreStartTarget<T>, BehaviorInterceptor.ReceiveTarget<T>, BehaviorInterceptor.SignalTarget<T>

Constructor Summary

Constructors

Constructor	Description
SimpleSupervisor(SupervisorStrategy ss, scala.reflect.ClassTag<Thr> evidence$2)

Method Summary

Modifier and Type	Method	Description
Behavior<T>	aroundReceive(TypedActorContext<java.lang.Object> ctx, java.lang.Object msg, BehaviorInterceptor.ReceiveTarget<T> target)	Intercept a message sent to the running actor.
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleException(TypedActorContext<java.lang.Object> ctx)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleExceptionOnStart(TypedActorContext<java.lang.Object> ctx, BehaviorInterceptor.PreStartTarget<T> target)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleReceiveException(TypedActorContext<java.lang.Object> ctx, BehaviorInterceptor.ReceiveTarget<T> target)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleSignalException(TypedActorContext<java.lang.Object> ctx, BehaviorInterceptor.SignalTarget<T> target)

Methods inherited from class akka.actor.typed.internal.AbstractSupervisor

aroundSignal, aroundStart, dropped, isInstanceOfTheThrowableClass, isSame, log, log, toString

Methods inherited from class akka.actor.typed.BehaviorInterceptor

interceptMessageClass

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSupervisor

public SimpleSupervisor(SupervisorStrategy ss,
                        scala.reflect.ClassTag<Thr> evidence$2)

Method Detail

aroundReceive

public Behavior<T> aroundReceive(TypedActorContext<java.lang.Object> ctx,
                                 java.lang.Object msg,
                                 BehaviorInterceptor.ReceiveTarget<T> target)

Description copied from class: BehaviorInterceptor

Intercept a message sent to the running actor. Pass the message on to the next behavior in the stack by passing it to target.apply, return Behaviors.same without invoking target to filter out the message.

Specified by:

aroundReceive in class BehaviorInterceptor<java.lang.Object,T>

Returns:

The behavior for next message or signal

handleException

protected scala.PartialFunction<java.lang.Throwable,Behavior<T>> handleException(TypedActorContext<java.lang.Object> ctx)

handleExceptionOnStart

protected scala.PartialFunction<java.lang.Throwable,Behavior<T>> handleExceptionOnStart(TypedActorContext<java.lang.Object> ctx,
                                                                                              BehaviorInterceptor.PreStartTarget<T> target)

Specified by:

handleExceptionOnStart in class AbstractSupervisor<T,Thr extends java.lang.Throwable>

handleReceiveException

protected scala.PartialFunction<java.lang.Throwable,Behavior<T>> handleReceiveException(TypedActorContext<java.lang.Object> ctx,
                                                                                              BehaviorInterceptor.ReceiveTarget<T> target)

Specified by:

handleReceiveException in class AbstractSupervisor<T,Thr extends java.lang.Throwable>

handleSignalException

protected scala.PartialFunction<java.lang.Throwable,Behavior<T>> handleSignalException(TypedActorContext<java.lang.Object> ctx,
                                                                                             BehaviorInterceptor.SignalTarget<T> target)

Specified by:

handleSignalException in class AbstractSupervisor<T,Thr extends java.lang.Throwable>