diff options
author | Diego <diegolparra@gmail.com> | 2014-08-06 23:13:33 -0300 |
---|---|---|
committer | Diego <diegolparra@gmail.com> | 2014-08-06 23:13:33 -0300 |
commit | aa4cd4da8bd5d218fafbe926f1e76dce5db44c94 (patch) | |
tree | be5974c086cb5628176a2f9f0e32f619b234c186 /kamon-core/src/main/scala/kamon/instrumentation | |
parent | 9878f62c88738ca056202f71f1725b34a109b77e (diff) | |
download | Kamon-aa4cd4da8bd5d218fafbe926f1e76dce5db44c94.tar.gz Kamon-aa4cd4da8bd5d218fafbe926f1e76dce5db44c94.tar.bz2 Kamon-aa4cd4da8bd5d218fafbe926f1e76dce5db44c94.zip |
! core: use the inline variant of TraceRecorder.withTraceContext via macros
Diffstat (limited to 'kamon-core/src/main/scala/kamon/instrumentation')
3 files changed, 4 insertions, 4 deletions
diff --git a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorCellInstrumentation.scala b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorCellInstrumentation.scala index 446bc487..235f5143 100644 --- a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorCellInstrumentation.scala +++ b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorCellInstrumentation.scala @@ -52,7 +52,7 @@ class ActorCellInstrumentation { val cellWithMetrics = cell.asInstanceOf[ActorCellMetrics] try { - TraceRecorder.withTraceContext(contextAndTimestamp.traceContext) { + TraceRecorder.withInlineTraceContextReplacement(contextAndTimestamp.traceContext) { pjp.proceed() } } finally { diff --git a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorLoggingInstrumentation.scala b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorLoggingInstrumentation.scala index ee9d442f..82b8304d 100644 --- a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorLoggingInstrumentation.scala +++ b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorLoggingInstrumentation.scala @@ -40,7 +40,7 @@ class ActorLoggingInstrumentation { @Around("withMdcInvocation(logSource, logEvent, logStatement)") def aroundWithMdcInvocation(pjp: ProceedingJoinPoint, logSource: String, logEvent: TraceContextAware, logStatement: () ⇒ _): Unit = { - TraceRecorder.withTraceContext(logEvent.traceContext) { + TraceRecorder.withInlineTraceContextReplacement(logEvent.traceContext) { pjp.proceed() } } diff --git a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorSystemMessageInstrumentation.scala b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorSystemMessageInstrumentation.scala index 9b6b6866..7845e90d 100644 --- a/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorSystemMessageInstrumentation.scala +++ b/kamon-core/src/main/scala/kamon/instrumentation/akka/ActorSystemMessageInstrumentation.scala @@ -31,7 +31,7 @@ class ActorSystemMessageInstrumentation { def aroundSystemMessageInvoke(pjp: ProceedingJoinPoint, messages: EarliestFirstSystemMessageList): Any = { if (messages.nonEmpty) { val ctx = messages.head.asInstanceOf[TraceContextAware].traceContext - TraceRecorder.withTraceContext(ctx)(pjp.proceed()) + TraceRecorder.withInlineTraceContextReplacement(ctx)(pjp.proceed()) } else pjp.proceed() } @@ -73,7 +73,7 @@ class TraceContextIntoRepointableActorRefMixin { @Around("repointableActorRefCreation(repointableActorRef)") def afterRepointableActorRefCreation(pjp: ProceedingJoinPoint, repointableActorRef: TraceContextAware): Any = { - TraceRecorder.withTraceContext(repointableActorRef.traceContext) { + TraceRecorder.withInlineTraceContextReplacement(repointableActorRef.traceContext) { pjp.proceed() } } |