From 231b5b0fc61438ec96e309436295e86808abdbb5 Mon Sep 17 00:00:00 2001 From: Ivan Topolnjak Date: Fri, 29 Nov 2013 09:59:37 -0300 Subject: instrumentation is back in place --- .../src/main/scala/test/SimpleRequestProcessor.scala | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) (limited to 'kamon-playground') 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) + +} -- cgit v1.2.3