Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- //Main.scala in src/main/scala
- import akka.actor.Actor
- import akka.actor.ActorSystem
- import akka.actor.Props
- import akka.actor.actorRef2Scala
- object Main extends App {
- val system = ActorSystem("System")
- val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-pinned-dispatcher"))
- //val a = system.actorOf(Props[TestActor].withDispatcher("akka.actor.my-dispatcher"))
- a ! "Hello World"
- system.shutdown()
- }
- class TestActor extends Actor {
- def receive = {
- case s: String => println(s)
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement