2011-12-15 18:19:40 +01:00
|
|
|
/**
|
|
|
|
|
* Copyright (C) 2009-2011 Typesafe Inc. <http://www.typesafe.com>
|
|
|
|
|
*/
|
2011-12-15 15:28:21 +01:00
|
|
|
package akka.docs.routing
|
|
|
|
|
|
|
|
|
|
import akka.actor.{ Actor, Props, ActorSystem }
|
|
|
|
|
import akka.routing.RoundRobinRouter
|
|
|
|
|
|
|
|
|
|
case class Message(nbr: Int)
|
|
|
|
|
|
|
|
|
|
class ExampleActor extends Actor {
|
|
|
|
|
def receive = {
|
|
|
|
|
case Message(nbr) ⇒ println("Received %s in router %s".format(nbr, self.path.name))
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
object RouterWithConfigExample extends App {
|
|
|
|
|
val system = ActorSystem("Example")
|
|
|
|
|
//#configurableRouting
|
|
|
|
|
val router = system.actorOf(Props[PrintlnActor].withRouter(RoundRobinRouter()),
|
|
|
|
|
"exampleActor")
|
|
|
|
|
//#configurableRouting
|
|
|
|
|
1 to 10 foreach { i ⇒ router ! Message(i) }
|
|
|
|
|
}
|
