akka/akka-core

Improve Documentation on Creating a Supervisor Strategy [Java]

开放

#16,729 创建于 2015年1月27日

 (4 条评论) (0 个反应) (0 位负责人)Scala (3,547 个派生)batch import
1 - triagedhelp wantedt:docs

仓库指标

星标
 (13,277 个星标)
PR 合并指标
 (PR 指标待抓取)

描述

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);

贡献者指南