From d7f1e195da11f977d5fdbf74598e499156de8dc4 Mon Sep 17 00:00:00 2001
From: Ivan Topolnak <ivantopo@gmail.com>
Date: Mon, 30 Sep 2013 11:21:25 -0300
Subject: wip

---
 kamon-core/src/main/scala/test/PingPong.scala | 31 ++++++++++++++++++++++++++-
 1 file changed, 30 insertions(+), 1 deletion(-)

(limited to 'kamon-core/src/main/scala/test/PingPong.scala')

diff --git a/kamon-core/src/main/scala/test/PingPong.scala b/kamon-core/src/main/scala/test/PingPong.scala
index 93aa322d..c942c6ab 100644
--- a/kamon-core/src/main/scala/test/PingPong.scala
+++ b/kamon-core/src/main/scala/test/PingPong.scala
@@ -1,11 +1,12 @@
 package test
 
-import akka.actor.{Deploy, Props, Actor, ActorSystem}
+import akka.actor._
 import java.util.concurrent.atomic.AtomicLong
 import kamon.Tracer
 import spray.routing.SimpleRoutingApp
 import akka.util.Timeout
 import spray.httpx.RequestBuilding
+import scala.concurrent.Future
 
 object PingPong extends App {
   import scala.concurrent.duration._
@@ -54,6 +55,7 @@ class Ponger extends Actor {
 object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding {
   import scala.concurrent.duration._
   import spray.client.pipelining._
+  import akka.pattern.ask
 
   implicit val system = ActorSystem("test")
   import system.dispatcher
@@ -61,6 +63,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
   implicit val timeout = Timeout(30 seconds)
 
   val pipeline = sendReceive
+  val replier = system.actorOf(Props[Replier])
 
   startServer(interface = "localhost", port = 9090) {
     get {
@@ -68,8 +71,34 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
         complete {
           pipeline(Get("http://www.despegar.com.ar")).map(r => "Ok")
         }
+      } ~
+      path("reply") {
+        complete {
+          if (Tracer.context().isEmpty)
+            println("ROUTE NO CONTEXT")
+
+          (replier ? "replytome").mapTo[String]
+        }
+      } ~
+      path("ok") {
+        complete("ok")
+      } ~
+      path("future") {
+        dynamic {
+          complete(Future { "OK" })
+        }
       }
     }
   }
 
 }
+
+class Replier extends Actor with ActorLogging {
+  def receive = {
+    case _ =>
+      if(Tracer.context.isEmpty)
+        log.warning("PROCESSING A MESSAGE WITHOUT CONTEXT")
+
+      sender ! "Ok"
+  }
+}
-- 
cgit v1.2.3