diff options
Diffstat (limited to 'kamon-core/src/main/scala/kamon/instrumentation/ActorLoggingInstrumentation.scala')
-rw-r--r-- | kamon-core/src/main/scala/kamon/instrumentation/ActorLoggingInstrumentation.scala | 32 |
1 files changed, 0 insertions, 32 deletions
diff --git a/kamon-core/src/main/scala/kamon/instrumentation/ActorLoggingInstrumentation.scala b/kamon-core/src/main/scala/kamon/instrumentation/ActorLoggingInstrumentation.scala deleted file mode 100644 index 9b53bd5d..00000000 --- a/kamon-core/src/main/scala/kamon/instrumentation/ActorLoggingInstrumentation.scala +++ /dev/null @@ -1,32 +0,0 @@ -package kamon.instrumentation - -import org.aspectj.lang.annotation.{Around, Pointcut, DeclareMixin, Aspect} -import kamon.{Tracer} -import org.aspectj.lang.ProceedingJoinPoint -import org.slf4j.MDC -import kamon.trace.TraceContext - -@Aspect -class ActorLoggingInstrumentation { - - - @DeclareMixin("akka.event.Logging.LogEvent+") - def traceContextMixin: ContextAware = new ContextAware { - def traceContext: Option[TraceContext] = Tracer.context() - } - - @Pointcut("execution(* akka.event.slf4j.Slf4jLogger.withMdc(..)) && args(logSource, logEvent, logStatement)") - def withMdcInvocation(logSource: String, logEvent: ContextAware, logStatement: () => _): Unit = {} - - @Around("withMdcInvocation(logSource, logEvent, logStatement)") - def putTraceContextInMDC(pjp: ProceedingJoinPoint, logSource: String, logEvent: ContextAware, logStatement: () => _): Unit = { - logEvent.traceContext match { - case Some(ctx) => - MDC.put("uow", ctx.uow) - pjp.proceed() - MDC.remove("uow") - - case None => pjp.proceed() - } - } -} |