aboutsummaryrefslogtreecommitdiff
path: root/kamon-akka/src/test/scala/kamon/akka/instrumentation/ActorCellInstrumentationSpec.scala
diff options
context:
space:
mode:
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.scala17
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
}
}