Package akka.actor.typed.internal

Class RestartSupervisor<O,T,Thr extends java.lang.Throwable>

java.lang.Object

akka.actor.typed.BehaviorInterceptor<O,I>

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

akka.actor.typed.internal.RestartSupervisor<O,T,Thr>

public class RestartSupervisor<O,T,Thr extends java.lang.Throwable>
extends AbstractSupervisor<O,T,Thr>

Calculates an exponential back off delay.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RestartSupervisor.ResetRestartCount
static class	RestartSupervisor.ResetRestartCount$
static class	RestartSupervisor.ScheduledRestart
static class	RestartSupervisor.ScheduledRestart$

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

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

Constructor Summary

Constructors

Constructor	Description
RestartSupervisor(Behavior<T> initial, SupervisorStrategy.RestartOrBackoff strategy, scala.reflect.ClassTag<Thr> evidence$5)

Method Summary

Modifier and Type	Method	Description
Behavior<T>	aroundReceive(TypedActorContext<O> ctx, O msg, BehaviorInterceptor.ReceiveTarget<T> target)	Intercept a message sent to the running actor.
Behavior<T>	aroundSignal(TypedActorContext<O> ctx, Signal signal, BehaviorInterceptor.SignalTarget<T> target)	Intercept a signal sent to the running actor.
static scala.concurrent.duration.FiniteDuration	calculateDelay(int restartCount, scala.concurrent.duration.FiniteDuration minBackoff, scala.concurrent.duration.FiniteDuration maxBackoff, double randomFactor)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleExceptionOnStart(TypedActorContext<O> ctx, BehaviorInterceptor.PreStartTarget<T> target)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleReceiveException(TypedActorContext<O> ctx, BehaviorInterceptor.ReceiveTarget<T> target)
protected scala.PartialFunction<java.lang.Throwable,Behavior<T>>	handleSignalException(TypedActorContext<O> ctx, BehaviorInterceptor.SignalTarget<T> target)

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

aroundStart, dropped, isInstanceOfTheThrowableClass, isSame, log, toString

Methods inherited from class akka.actor.typed.BehaviorInterceptor

interceptMessageType

Methods inherited from class java.lang.Object

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

Constructor Detail

RestartSupervisor

public RestartSupervisor(Behavior<T> initial,
                         SupervisorStrategy.RestartOrBackoff strategy,
                         scala.reflect.ClassTag<Thr> evidence$5)

Method Detail

calculateDelay

public static scala.concurrent.duration.FiniteDuration calculateDelay(int restartCount,
                                                                      scala.concurrent.duration.FiniteDuration minBackoff,
                                                                      scala.concurrent.duration.FiniteDuration maxBackoff,
                                                                      double randomFactor)

aroundSignal

public Behavior<T> aroundSignal(TypedActorContext<O> ctx,
                                Signal signal,
                                BehaviorInterceptor.SignalTarget<T> target)

Description copied from class: BehaviorInterceptor

Intercept a signal sent to the running actor. Pass the signal on to the next behavior in the stack by passing it to target.apply.

Overrides:

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

Parameters:

ctx - (undocumented)

signal - (undocumented)

target - (undocumented)

Returns:

The behavior for next message or signal

aroundReceive

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

Parameters:

ctx - (undocumented)

msg - (undocumented)

target - (undocumented)

Returns:

The behavior for next message or signal

handleExceptionOnStart

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

Specified by:

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

handleSignalException

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

Specified by:

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

handleReceiveException

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

Specified by:

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