diff options
author | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-08 18:16:14 -0300 |
---|---|---|
committer | Ivan Topolnak <ivantopo@gmail.com> | 2013-11-08 18:16:14 -0300 |
commit | 0a9d299e56db77481c47e23d05491c091d746f52 (patch) | |
tree | ee1c227fc0c8f3ed6e40863097e5e1e8d20434b4 /kamon-playground/src/main/scala | |
parent | bf86900669d649308f4914c54e6fe076510506a6 (diff) | |
download | Kamon-0a9d299e56db77481c47e23d05491c091d746f52.tar.gz Kamon-0a9d299e56db77481c47e23d05491c091d746f52.tar.bz2 Kamon-0a9d299e56db77481c47e23d05491c091d746f52.zip |
wip
Diffstat (limited to 'kamon-playground/src/main/scala')
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 8 |
1 files changed, 6 insertions, 2 deletions
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 { |