diff options
Diffstat (limited to 'kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala')
-rw-r--r-- | kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala b/kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala index 457b8351..40e82011 100644 --- a/kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala +++ b/kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala @@ -38,12 +38,16 @@ class ActorCellInstrumentationSpec extends BaseKamonSpec("actor-cell-instrumenta } "propagate the TraceContext using tell" in new EchoActorFixture { - val testTraceContext = Tracer.withContext(newContext("tell-reply")) { - ctxEchoActor.tell("test", testActor) - Tracer.currentContext + for (i ← 1 to 10000) { + val ta = system.actorOf(Props[TraceContextEcho]) + val testTraceContext = Tracer.withContext(newContext("tell-reply", i.toString)) { + ta.tell("test", testActor) + Tracer.currentContext + } + + expectMsg(testTraceContext) + system.stop(ta) } - - expectMsg(testTraceContext) } "propagate the TraceContext using ask" in new EchoActorFixture { @@ -116,7 +120,8 @@ class ActorCellInstrumentationSpec extends BaseKamonSpec("actor-cell-instrumenta class TraceContextEcho extends Actor { def receive = { - case msg: String ⇒ sender ! Tracer.currentContext + case msg: String ⇒ + sender ! Tracer.currentContext } } |