aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/test/PingPong.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-core/src/main/scala/test/PingPong.scala')
-rw-r--r--kamon-core/src/main/scala/test/PingPong.scala16
1 files changed, 14 insertions, 2 deletions
diff --git a/kamon-core/src/main/scala/test/PingPong.scala b/kamon-core/src/main/scala/test/PingPong.scala
index b78f1d79..93aa322d 100644
--- a/kamon-core/src/main/scala/test/PingPong.scala
+++ b/kamon-core/src/main/scala/test/PingPong.scala
@@ -4,6 +4,8 @@ import akka.actor.{Deploy, Props, Actor, ActorSystem}
import java.util.concurrent.atomic.AtomicLong
import kamon.Tracer
import spray.routing.SimpleRoutingApp
+import akka.util.Timeout
+import spray.httpx.RequestBuilding
object PingPong extends App {
import scala.concurrent.duration._
@@ -49,13 +51,23 @@ class Ponger extends Actor {
}
-object SimpleRequestProcessor extends App with SimpleRoutingApp {
+object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding {
+ import scala.concurrent.duration._
+ import spray.client.pipelining._
+
implicit val system = ActorSystem("test")
+ import system.dispatcher
+
+ implicit val timeout = Timeout(30 seconds)
+
+ val pipeline = sendReceive
startServer(interface = "localhost", port = 9090) {
get {
path("test"){
- complete("OK")
+ complete {
+ pipeline(Get("http://www.despegar.com.ar")).map(r => "Ok")
+ }
}
}
}