私は Akka を初めて使用し、入門シリーズに取り組もうとしています。Dispatcher を構成することができたので、PinnedDispatcher を構成しようとしています。はじめにのページの指示に従っているのに、エラー メッセージが表示される
[WARN] [06/19/2013 12:53:13.791] [System-akka.actor.default-dispatcher-5] [Dispatchers] Dispatcher [akka.actor.my-pinned-dispatcher] not configured, using default-dispatcher
スカラコードは次のとおりです。
val system = ActorSystem("System")
val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-pinned-dispatcher")) //this doesnt work
val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-dispatcher")) //this does work
a ! "Hello World"
system.shutdown()
class TestActor extends Actor {
def receive = {
case s: String => println(s)
}
}
ここに私のapplication.confがあります
akka {
actor {
my-pinned-dispatcher {
executor = "thread-pool-executor"
type = PinnedDispatcher
}
my-dispatcher {
type = Dispatcher
executor = "fork-join-executor"
fork-join-executor {
parallelism-min = 2
parallelism-factor = 2.0
parallelism-max = 10
}
throughput = 100
}
}
}
PinnedDispatcher を間違って構成しましたか?