akka.typed.patterns

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

java.lang.Object

akka.typed.Behavior<T>

akka.typed.patterns.Restarter<T,Thr>

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public final class Restarter<T,Thr extends java.lang.Throwable>
extends Behavior<T>
implements scala.Product, scala.Serializable

Simple supervision strategy that restarts the underlying behavior for all failures of type Thr.

FIXME add limited restarts and back-off (with limited buffering or vacation responder) FIXME write tests that ensure that all Behaviors are okay with getting PostRestart as first signal

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Restarter.Apply<Thr extends java.lang.Throwable>

Nested classes/interfaces inherited from class akka.typed.Behavior

Behavior.emptyBehavior$, Behavior.ignoreBehavior$, Behavior.sameBehavior$, Behavior.stoppedBehavior$, Behavior.unhandledBehavior$

Constructor Summary

Constructors

Constructor and Description
Restarter(Behavior<T> initialBehavior, boolean resume, scala.reflect.ClassTag<Thr> evidence$1)

Method Summary

Modifier and Type	Method and Description
static <Thr extends java.lang.Throwable> Restarter.Apply<Thr>	apply(boolean resume, scala.reflect.ClassTag<Thr> evidence$2)
abstract static boolean	canEqual(java.lang.Object that)
abstract static boolean	equals(java.lang.Object that)
Behavior<T>	initialBehavior()
Behavior<T>	management(ActorContext<T> ctx, Signal signal) Process an incoming Signal and return the next behavior.
Behavior<T>	message(ActorContext<T> ctx, T msg) Process an incoming message and return the next behavior.
static <U extends T> Behavior<U>	narrow()
abstract static int	productArity()
abstract static java.lang.Object	productElement(int n)
static scala.collection.Iterator<java.lang.Object>	productIterator()
static java.lang.String	productPrefix()
boolean	resume()

Methods inherited from class akka.typed.Behavior

canonicalize, isAlive, isUnhandled, narrow, preStart, validateAsInitial

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Restarter

public Restarter(Behavior<T> initialBehavior,
                 boolean resume,
                 scala.reflect.ClassTag<Thr> evidence$1)

Method Detail

apply

public static <Thr extends java.lang.Throwable> Restarter.Apply<Thr> apply(boolean resume,
                                                                           scala.reflect.ClassTag<Thr> evidence$2)

narrow

public static <U extends T> Behavior<U> narrow()

canEqual

public abstract static boolean canEqual(java.lang.Object that)

equals

public abstract static boolean equals(java.lang.Object that)

productElement

public abstract static java.lang.Object productElement(int n)

productArity

public abstract static int productArity()

productIterator

public static scala.collection.Iterator<java.lang.Object> productIterator()

productPrefix

public static java.lang.String productPrefix()

initialBehavior

public Behavior<T> initialBehavior()

resume

public boolean resume()

management

public Behavior<T> management(ActorContext<T> ctx,
                              Signal signal)

Description copied from class: Behavior

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:

management in class Behavior<T>

Parameters:

ctx - (undocumented)

signal - (undocumented)

Returns:

(undocumented)

message

public Behavior<T> message(ActorContext<T> ctx,
                           T msg)

Description copied from class: Behavior

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 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:

message in class Behavior<T>

Parameters:

ctx - (undocumented)

msg - (undocumented)

Returns:

(undocumented)