aboutsummaryrefslogtreecommitdiff
path: root/kamon-playground/src
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-playground/src')
-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)
+
+}