aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground
diff options
context:
space:
mode:
authorIvan Topolnjak <ivantopo@gmail.com>2013-11-29 09:59:37 -0300
committerIvan Topolnjak <ivantopo@gmail.com>2013-11-29 09:59:37 -0300
commit231b5b0fc61438ec96e309436295e86808abdbb5 (patch)
tree10288215da3562b5d523b4d2d97b703056cfe4fa /kamon-playground
parentb80e4bd135ed50b01def5a4c2f7c42983efb54fd (diff)
downloadKamon-231b5b0fc61438ec96e309436295e86808abdbb5.tar.gz
Kamon-231b5b0fc61438ec96e309436295e86808abdbb5.tar.bz2
Kamon-231b5b0fc61438ec96e309436295e86808abdbb5.zip
instrumentation is back in place
Diffstat (limited to 'kamon-playground')
-rw-r--r--kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala19
1 files changed, 19 insertions, 0 deletions
diff --git a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
index 1c1dba4f..53cd28ff 100644
--- a/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
+++ b/kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala
@@ -52,6 +52,12 @@ object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuil
Future.sequence(futures).map(l ⇒ "Ok")
}
}
+ } ~ {
+ path("site") {
+ complete {
+ pipeline(Get("http://localhost:4000/"))
+ }
+ }
} ~
path("reply" / Segment) { reqID ⇒
uow {
@@ -116,3 +122,16 @@ class Replier extends Actor with ActorLogging {
sender ! anything
}
}
+
+object PingPong extends App {
+ val system = ActorSystem()
+ val pinger = system.actorOf(Props(new Actor {
+ def receive: Actor.Receive = { case "pong" => sender ! "ping" }
+ }))
+ val ponger = system.actorOf(Props(new Actor {
+ def receive: Actor.Receive = { case "ping" => sender ! "pong" }
+ }))
+
+ pinger.tell("pong", ponger)
+
+}