path: root/kamon-core/src/main/scala/test/PingPong.scala

package test

import akka.actor.{Deploy, 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 {
  val ponger = context.actorOf(Props[Ponger], "ponger#")
  val ponger2 = context.actorOf(Props[Ponger], "ponger#")

  def receive = {
    case Pong => ponger ! Ping
  }
}

class Ponger extends Actor {
  def receive = {
    case Ping => sender ! Pong
  }
}