diff options
Diffstat (limited to 'src/main/aspectj/kamon/instrumentation/PromiseCompletingRunnableInstrumentation.aj')
-rw-r--r-- | src/main/aspectj/kamon/instrumentation/PromiseCompletingRunnableInstrumentation.aj | 28 |
1 files changed, 0 insertions, 28 deletions
diff --git a/src/main/aspectj/kamon/instrumentation/PromiseCompletingRunnableInstrumentation.aj b/src/main/aspectj/kamon/instrumentation/PromiseCompletingRunnableInstrumentation.aj deleted file mode 100644 index 5ae26d75..00000000 --- a/src/main/aspectj/kamon/instrumentation/PromiseCompletingRunnableInstrumentation.aj +++ /dev/null @@ -1,28 +0,0 @@ -package kamon.instrumentation; - -import kamon.TraceContext; -import scala.concurrent.impl.Future; -import scala.Option; - -privileged public aspect PromiseCompletingRunnableInstrumentation { - - declare parents : Future.PromiseCompletingRunnable extends TraceContextHolder; - - pointcut run(scala.concurrent.impl.Future.PromiseCompletingRunnable runnable) - : execution(* scala.concurrent.impl.Future.PromiseCompletingRunnable.run()) && this(runnable); - - void around(Object runnable) - : run(runnable) { - - TraceContextHolder contextHolder = (TraceContextHolder) runnable; - - if(contextHolder.context().isDefined()) { - TraceContext.set(contextHolder.context().get()); - proceed(contextHolder); - TraceContext.clear(); - - } else { - proceed(contextHolder); - } - } -} |