diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2013-11-29 09:59:37 -0300 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2013-11-29 09:59:37 -0300 |
commit | 231b5b0fc61438ec96e309436295e86808abdbb5 (patch) | |
tree | 10288215da3562b5d523b4d2d97b703056cfe4fa /kamon-playground/src/main/scala | |
parent | b80e4bd135ed50b01def5a4c2f7c42983efb54fd (diff) | |
download | Kamon-231b5b0fc61438ec96e309436295e86808abdbb5.tar.gz Kamon-231b5b0fc61438ec96e309436295e86808abdbb5.tar.bz2 Kamon-231b5b0fc61438ec96e309436295e86808abdbb5.zip |
instrumentation is back in place
Diffstat (limited to 'kamon-playground/src/main/scala')
-rw-r--r-- | kamon-playground/src/main/scala/test/SimpleRequestProcessor.scala | 19 |
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) + +} |