diff options
author | Ivan Topolnjak <ivantopo@gmail.com> | 2013-11-23 21:57:27 -0300 |
---|---|---|
committer | Ivan Topolnjak <ivantopo@gmail.com> | 2013-11-23 21:57:27 -0300 |
commit | f9b596754feb657f1130eebd0cc4ac2a5e741518 (patch) | |
tree | b3dab1bd1591e2ab045eab28dc7db4db0b9f743d /kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala | |
parent | 6ba7487204e0339437c7279e6330fc03419a2c5c (diff) | |
download | Kamon-f9b596754feb657f1130eebd0cc4ac2a5e741518.tar.gz Kamon-f9b596754feb657f1130eebd0cc4ac2a5e741518.tar.bz2 Kamon-f9b596754feb657f1130eebd0cc4ac2a5e741518.zip |
Little clean up to actor message passing tracing
Diffstat (limited to 'kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala')
-rw-r--r-- | kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala b/kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala new file mode 100644 index 00000000..096ac986 --- /dev/null +++ b/kamon-trace/src/test/scala/kamon/ActorMessagePassingTracingSpec.scala @@ -0,0 +1,73 @@ +package kamon + +import org.scalatest.{WordSpecLike, Matchers} +import akka.actor.{ActorRef, Actor, Props, ActorSystem} + +import akka.testkit.{ImplicitSender, TestKit} +import kamon.trace.Trace +import akka.pattern.{pipe, ask} +import akka.util.Timeout +import scala.concurrent.duration._ +import scala.concurrent.{Await, Future} +import akka.routing.RoundRobinRouter +import kamon.trace.TraceContext + + +class ActorMessagePassingTracingSpec extends TestKit(ActorSystem("actor-message-passing-tracing-spec")) with WordSpecLike with ImplicitSender { + implicit val executionContext = system.dispatcher + + "the message passing instrumentation" should { + "propagate the TraceContext using bang" in new TraceContextEchoFixture { + Trace.withValue(testTraceContext) { + ctxEchoActor ! "test" + } + + expectMsg(testTraceContext) + } + + "propagate the TraceContext using tell" in new TraceContextEchoFixture { + Trace.withValue(testTraceContext) { + ctxEchoActor.tell("test", testActor) + } + + expectMsg(testTraceContext) + } + + "propagate the TraceContext using ask" in new TraceContextEchoFixture { + implicit val timeout = Timeout(1 seconds) + Trace.withValue(testTraceContext) { + // The pipe pattern use Futures internally, so FutureTracing test should cover the underpinnings of it. + (ctxEchoActor ? "test") pipeTo(testActor) + } + + expectMsg(testTraceContext) + } + + "propagate the TraceContext to actors behind a router" in new RoutedTraceContextEchoFixture { + Trace.withValue(testTraceContext) { + ctxEchoActor ! "test" + } + + expectMsg(testTraceContext) + } + } + + trait TraceContextEchoFixture { + val testTraceContext = Some(Trace.newTraceContext("")) + val ctxEchoActor = system.actorOf(Props[TraceContextEcho]) + } + + trait RoutedTraceContextEchoFixture extends TraceContextEchoFixture { + override val ctxEchoActor = system.actorOf(Props[TraceContextEcho].withRouter(RoundRobinRouter(nrOfInstances = 1))) + } +} + +class TraceContextEcho extends Actor { + def receive = { + case msg: String ⇒ sender ! Trace.context() + } +} + + + + |