diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-07-10 18:13:49 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-07-10 18:13:49 -0300 |
commit | e8dd6c83986f1ecd2d717c39bffe900b23b68854 (patch) | |
tree | 43e0feaa42225a3770922a9366e126590225719a /src/main/scala/test/PingPong.scala | |
parent | d1e22b3f446c89413c67421f19ab5215ebdfcd43 (diff) | |
download | Kamon-e8dd6c83986f1ecd2d717c39bffe900b23b68854.tar.gz Kamon-e8dd6c83986f1ecd2d717c39bffe900b23b68854.tar.bz2 Kamon-e8dd6c83986f1ecd2d717c39bffe900b23b68854.zip |
complete disaster, wip
Diffstat (limited to 'src/main/scala/test/PingPong.scala')
-rw-r--r-- | src/main/scala/test/PingPong.scala | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/src/main/scala/test/PingPong.scala b/src/main/scala/test/PingPong.scala new file mode 100644 index 00000000..f9d6869c --- /dev/null +++ b/src/main/scala/test/PingPong.scala @@ -0,0 +1,34 @@ +package test + +import akka.actor.{Props, Actor, ActorSystem} + +object PingPong extends App { + + val as = ActorSystem("ping-pong") + + val pinger = as.actorOf(Props[Pinger]) + val ponger = as.actorOf(Props[Ponger]) + + pinger.tell(Pong, ponger) + + + Thread.sleep(30000) + as.shutdown() + + +} + +case object Ping +case object Pong + +class Pinger extends Actor { + def receive = { + case Pong => sender ! Ping + } +} + +class Ponger extends Actor { + def receive = { + case Ping => sender ! Pong + } +} |