aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala')
-rw-r--r--kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala13
1 files changed, 12 insertions, 1 deletions
diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
index 1db2db67..b6bcc677 100644
--- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
+++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
@@ -21,6 +21,7 @@ import akka.routing.RoundRobinPool
import akka.util.Timeout
import kamon.Kamon
import kamon.metric.Subscriptions.TickMetricSnapshot
+import kamon.metric.TraceMetrics.HttpClientRequest
import kamon.metric._
import kamon.spray.KamonTraceDirectives
import kamon.trace.TraceRecorder
@@ -124,6 +125,16 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
throw new NullPointerException
"okk"
}
+ } ~
+ path("segment") {
+ complete {
+ val segment = TraceRecorder.startSegment(HttpClientRequest("hello-world"))
+ (replier ? "hello").mapTo[String].onComplete { t =>
+ segment.get.finish()
+ }
+
+ "segment"
+ }
}
}
}
@@ -166,7 +177,7 @@ class Replier extends Actor with ActorLogging {
if (TraceRecorder.currentContext.isEmpty)
log.warning("PROCESSING A MESSAGE WITHOUT CONTEXT")
- log.info("Processing at the Replier, and self is: {}", self)
+ //log.info("Processing at the Replier, and self is: {}", self)
sender ! anything
}
}