upgrading to akka 2.2

1 files changed, 34 insertions, 0 deletions

diff --git a/kamon-core/src/main/scala/test/PingPong.scala b/kamon-core/src/main/scala/test/PingPong.scala
new file mode 100644
index 00000000..f9d6869c
--- /dev/null
+++ b/kamon-core/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
+  }
+}