Package org.apache.pekko.actor.typed.internal

Class SimpleSupervisor<T,Thr extends Throwable>

java.lang.Object

org.apache.pekko.actor.typed.BehaviorInterceptor<Object,I>

org.apache.pekko.actor.typed.internal.AbstractSupervisor<T,Thr>

org.apache.pekko.actor.typed.internal.SimpleSupervisor<T,Thr>

Direct Known Subclasses:

ResumeSupervisor, StopSupervisor

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

For cases where O == I for BehaviorInterceptor.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.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<Object> ctx, Object msg, BehaviorInterceptor.ReceiveTarget<T> target)	Intercept a message sent to the running actor.
protected scala.PartialFunction<Throwable,Behavior<T>>	handleException(TypedActorContext<Object> ctx)
protected scala.PartialFunction<Throwable,Behavior<T>>	handleExceptionOnStart(TypedActorContext<Object> ctx, BehaviorInterceptor.PreStartTarget<T> target)
protected scala.PartialFunction<Throwable,Behavior<T>>	handleReceiveException(TypedActorContext<Object> ctx, BehaviorInterceptor.ReceiveTarget<T> target)
protected scala.PartialFunction<Throwable,Behavior<T>>	handleSignalException(TypedActorContext<Object> ctx, BehaviorInterceptor.SignalTarget<T> target)

Methods inherited from class org.apache.pekko.actor.typed.internal.AbstractSupervisor

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

Methods inherited from class org.apache.pekko.actor.typed.BehaviorInterceptor

interceptMessageClass

Methods inherited from class java.lang.Object

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

Constructor Details

SimpleSupervisor

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

Method Details

aroundReceive

public Behavior<T> aroundReceive(TypedActorContext<Object> ctx,
 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<Object,T>

Returns:

The behavior for next message or signal

handleException

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

handleExceptionOnStart

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

Specified by:

handleExceptionOnStart in class AbstractSupervisor<T,Thr extends Throwable>

handleReceiveException

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

Specified by:

handleReceiveException in class AbstractSupervisor<T,Thr extends Throwable>

handleSignalException

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

Specified by:

handleSignalException in class AbstractSupervisor<T,Thr extends Throwable>