From 0a9d299e56db77481c47e23d05491c091d746f52 Mon Sep 17 00:00:00 2001 From: Ivan Topolnak Date: Fri, 8 Nov 2013 18:16:14 -0300 Subject: wip --- kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'kamon-playground/src/main/scala') diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala index 628a2c41..5e1bfdd3 100644 --- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala +++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala @@ -8,6 +8,7 @@ import scala.concurrent.{Await, Future} import kamon.spray.UowDirectives import kamon.trace.Trace import kamon.Kamon +import scala.util.Random object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding with UowDirectives { import scala.concurrent.duration._ @@ -25,7 +26,7 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil val pipeline = sendReceive val replier = system.actorOf(Props[Replier]) - + val random = new Random() startServer(interface = "localhost", port = 9090) { get { path("test"){ @@ -48,7 +49,10 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil } } ~ path("ok") { - complete("ok") + complete{ + //Thread.sleep(random.nextInt(1) + random.nextInt(5) + random.nextInt(2)) + "ok" + } } ~ path("future") { dynamic { -- cgit v1.2.3