akka/akka-core

Improve Documentation on Creating a Supervisor Strategy [Java]

オープン

#16,729 opened on 2015/01/27

 (4 件のコメント) (0 件のリアクション) (0 人の担当者)Scala (3,547 件のフォーク)batch import
1 - triagedhelp wantedt:docs

Repository metrics

Stars
 (13,277 個のスター)
PR merge metrics
 (平均マージ 8d 19h) (30d で 10 merged PRs)

説明

Regarding http://doc.akka.io/docs/akka/snapshot/java/fault-tolerance.html: The code samples don't compile out-of-the-box. Also, the documentation should say how the default strategy (http://doc.akka.io/docs/akka/snapshot/java/fault-tolerance.html#Default_Supervisor_Strategy) is implemented, so when you start implementing your own strategy, you can start from there.

Here's what I suppose is a working replica in Java of the default implementation:

new OneForOneStrategy(-1, Duration.Inf(), new Function<Throwable, SupervisorStrategy.Directive>() {
        @Override
        public SupervisorStrategy.Directive apply(final Throwable throwable) throws Exception {
            if (throwable instanceof ActorInitializationException) {
                return SupervisorStrategy.stop();
            } else if (throwable instanceof ActorKilledException) {
                return SupervisorStrategy.stop();
            } else if (throwable instanceof DeathPactException) {
                return SupervisorStrategy.stop();
            } else if (throwable instanceof Exception) {
                return SupervisorStrategy.restart();
            } else {
                return SupervisorStrategy.escalate();
            }
        }
    }, true);

コントリビューターガイド