scala – 播放2.1.1不加载自定义Akka调度程序

发布时间：2020-12-16 09:57:34 所属栏目：安全来源：网络整理

导读：我正在使用Play 2.1.1,在application.conf中我添加了以下自定义调度程序： # Dispatcher for round-robin actorsplay { akka { actor { rr-dispatcher = { type = BalancingDispatcher executor = fork-join-executor fork-join-executor { parallelism-min

我正在使用Play 2.1.1,在application.conf中我添加了以下自定义调度程序：

# Dispatcher for round-robin actors
play {
    akka {
        actor {
            rr-dispatcher = {
                type = BalancingDispatcher
                executor = fork-join-executor
                fork-join-executor {
                    parallelism-min = 2
                    parallelism-factor = 2
                    parallelism-max = 24
                }
                # messages per actor before jumping
                throughput = 100
            }
        }
    }
}

我尝试在演员身上使用它：

private val default = Akka.system.actorOf(Props[MessageRouterActor].withRouter(FromConfig()).withDispatcher("rr-dispatcher"),"msgRouter")

但我得到这条消息说明找不到调度员：

[info] play - Starting application default Akka system.
[WARN] [04/20/2013 22:05:12.069] [application-akka.actor.default-dispatcher-5] [Dispatchers] Dispatcher [rr-dispatcher] not configured,using default-dispatcher

据我所知,这似乎是添加它的正确方法.谁知道问题是什么？

解决方法

你必须把完整的配置值路径：withDispatcher(“akka.actor.rr-dispatcher”)(或者甚至是“play.akka.actor.rr-dispatcher”)

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!