akka.cluster.fastfailover

Class FailureStrategyBuilder

java.lang.Object

akka.cluster.fastfailover.FailureStrategyBuilder

public class FailureStrategyBuilder
extends java.lang.Object

Used for building a partial function for FastFailover failure strategies.

Example:

 PartialFunction<Throwable, FastFailover.FailureDirective> strategy = FailureStrategyBuilder.
     match(IllegalArgumentException.class, e -> FastFailover.fail()).
     match(AskTimeoutException.class, e -> FastFailover.failover()).build();
 

Method Summary

Modifier and Type	Method and Description
static <P extends java.lang.Throwable> akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective>	match(java.lang.Class<P> type, akka.japi.pf.FI.Apply<P,FastFailover.FailureDirective> apply) Return a new PFBuilder with a case statement added.
static <P extends java.lang.Throwable> akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective>	match(java.lang.Class<P> type, akka.japi.pf.FI.TypedPredicate<P> predicate, akka.japi.pf.FI.Apply<P,FastFailover.FailureDirective> apply) Return a new PFBuilder with a case statement added.
static akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective>	matchAny(akka.japi.pf.FI.Apply<java.lang.Throwable,FastFailover.FailureDirective> apply) Return a new PFBuilder with a case statement added.

Methods inherited from class java.lang.Object

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

Method Detail

match

public static <P extends java.lang.Throwable> akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective> match(java.lang.Class<P> type,
                                                                                                                              akka.japi.pf.FI.Apply<P,FastFailover.FailureDirective> apply)

Return a new PFBuilder with a case statement added.

Parameters:

type - a type to match the argument against

apply - an action to apply to the argument if the type matches

Returns:

a builder with the case statement added

match

public static <P extends java.lang.Throwable> akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective> match(java.lang.Class<P> type,
                                                                                                                              akka.japi.pf.FI.TypedPredicate<P> predicate,
                                                                                                                              akka.japi.pf.FI.Apply<P,FastFailover.FailureDirective> apply)

Return a new PFBuilder with a case statement added.

Parameters:

type - a type to match the argument against

predicate - a predicate that will be evaluated on the argument if the type matches

apply - an action to apply to the argument if the type matches and the predicate returns true

Returns:

a builder with the case statement added

matchAny

public static akka.japi.pf.PFBuilder<java.lang.Throwable,FastFailover.FailureDirective> matchAny(akka.japi.pf.FI.Apply<java.lang.Throwable,FastFailover.FailureDirective> apply)

Return a new PFBuilder with a case statement added.

Parameters:

apply - an action to apply to the argument

Returns:

a builder with the case statement added