kamon-core/src/main/scala/test/PingPong.scala


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
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
  }
}