public class OneForOneStrategy extends SupervisorStrategy implements scala.Product, scala.Serializable
Directive
(Resume, Restart, Stop) specified in the Decider
to the child actor that failed, as opposed to AllForOneStrategy
that applies
it to all children.
SupervisorStrategy.Directive, SupervisorStrategy.Escalate$, SupervisorStrategy.Restart$, SupervisorStrategy.Resume$, SupervisorStrategy.Stop$
Constructor and Description |
---|
OneForOneStrategy(boolean loggingEnabled,
scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
Java API: compatible with lambda expressions
This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing.
|
OneForOneStrategy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
boolean loggingEnabled,
scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider) |
OneForOneStrategy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
Function<java.lang.Throwable,SupervisorStrategy.Directive> decider)
Java API
|
OneForOneStrategy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
Function<java.lang.Throwable,SupervisorStrategy.Directive> decider,
boolean loggingEnabled)
Java API
|
OneForOneStrategy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
java.lang.Iterable<java.lang.Class<? extends java.lang.Throwable>> trapExit)
Java API
|
OneForOneStrategy(int maxNrOfRetries,
scala.concurrent.duration.Duration withinTimeRange,
scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
Java API: compatible with lambda expressions
This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing.
|
OneForOneStrategy(scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
Java API: compatible with lambda expressions
This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing.
|
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> |
decider()
Returns the Decider that is associated with this SupervisorStrategy.
|
void |
handleChildTerminated(ActorContext context,
ActorRef child,
scala.collection.Iterable<ActorRef> children)
This method is called after the child has been removed from the set of children.
|
boolean |
loggingEnabled()
Logging of actor failures is done when this is
true . |
int |
maxNrOfRetries() |
void |
processFailure(ActorContext context,
boolean restart,
ActorRef child,
java.lang.Throwable cause,
ChildRestartStats stats,
scala.collection.Iterable<ChildRestartStats> children)
This method is called to act on the failure of a child: restart if the flag is true, stop otherwise.
|
scala.concurrent.duration.Duration |
withinTimeRange() |
defaultDecider, defaultStrategy, escalate, escalateDefault, handleFailure, logFailure, makeDecider, makeDecider, makeDecider, makeDecider, restart, restartChild, resume, resumeChild, seqThrowable2Decider, stop, stoppingStrategy
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public OneForOneStrategy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, boolean loggingEnabled, scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public OneForOneStrategy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, Function<java.lang.Throwable,SupervisorStrategy.Directive> decider, boolean loggingEnabled)
public OneForOneStrategy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, Function<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public OneForOneStrategy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, java.lang.Iterable<java.lang.Class<? extends java.lang.Throwable>> trapExit)
public OneForOneStrategy(int maxNrOfRetries, scala.concurrent.duration.Duration withinTimeRange, scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public OneForOneStrategy(boolean loggingEnabled, scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public OneForOneStrategy(scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider)
public int maxNrOfRetries()
public scala.concurrent.duration.Duration withinTimeRange()
public boolean loggingEnabled()
SupervisorStrategy
true
.loggingEnabled
in class SupervisorStrategy
public scala.PartialFunction<java.lang.Throwable,SupervisorStrategy.Directive> decider()
SupervisorStrategy
handleFailure
to obtain the Directive to be applied.decider
in class SupervisorStrategy
public void handleChildTerminated(ActorContext context, ActorRef child, scala.collection.Iterable<ActorRef> children)
SupervisorStrategy
handleChildTerminated
in class SupervisorStrategy
public void processFailure(ActorContext context, boolean restart, ActorRef child, java.lang.Throwable cause, ChildRestartStats stats, scala.collection.Iterable<ChildRestartStats> children)
SupervisorStrategy
processFailure
in class SupervisorStrategy