diff options
| author | Diego <diegolparra@gmail.com> | 2014-10-21 12:49:28 -0300 |
|---|---|---|
| committer | Diego <diegolparra@gmail.com> | 2014-10-21 12:49:28 -0300 |
| commit | 52233d1ddef10b3c40df134b33f0d255dce85ae5 (patch) | |
| tree | 57e89019b00b2b85aa3812ac1131b653585e6a56 /kamon-core/src | |
| parent | 49eb51ed37d8af28377eb398afe5e8f6c374396e (diff) | |
| download | Kamon-52233d1ddef10b3c40df134b33f0d255dce85ae5.tar.gz Kamon-52233d1ddef10b3c40df134b33f0d255dce85ae5.tar.bz2 Kamon-52233d1ddef10b3c40df134b33f0d255dce85ae5.zip | |
= core: exclude CallerThreadDispatcher from instrumentation, change Dispatcher to MessageDispatcher in DispatcherInstrumentation and fixes #95
Diffstat (limited to 'kamon-core/src')
| -rw-r--r-- | kamon-core/src/main/resources/META-INF/aop.xml | 2 | ||||
| -rw-r--r-- | kamon-core/src/main/scala/kamon/instrumentation/akka/DispatcherInstrumentation.scala | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/kamon-core/src/main/resources/META-INF/aop.xml b/kamon-core/src/main/resources/META-INF/aop.xml index cd7b1645..ee2af95a 100644 --- a/kamon-core/src/main/resources/META-INF/aop.xml +++ b/kamon-core/src/main/resources/META-INF/aop.xml @@ -38,6 +38,8 @@ <!-- For some weird reason ByteString produces a java.lang.VerifyError after going through the weaver. --> <exclude within="akka.util.ByteString"/> + <!-- Exclude CallingThreadDispatcher, is only for test purposes --> + <exclude within="akka.testkit.CallingThreadDispatcher"/> </weaver> </aspectj>
\ No newline at end of file diff --git a/kamon-core/src/main/scala/kamon/instrumentation/akka/DispatcherInstrumentation.scala b/kamon-core/src/main/scala/kamon/instrumentation/akka/DispatcherInstrumentation.scala index db366e8c..8b3af3d6 100644 --- a/kamon-core/src/main/scala/kamon/instrumentation/akka/DispatcherInstrumentation.scala +++ b/kamon-core/src/main/scala/kamon/instrumentation/akka/DispatcherInstrumentation.scala @@ -105,7 +105,7 @@ class DispatcherInstrumentation { @Aspect class DispatcherMetricCollectionInfoIntoDispatcherMixin { - @DeclareMixin("akka.dispatch.Dispatcher") + @DeclareMixin("akka.dispatch.MessageDispatcher") def mixinDispatcherMetricsToMessageDispatcher: DispatcherMetricCollectionInfo = new DispatcherMetricCollectionInfo {} @DeclareMixin("akka.dispatch.Dispatchers") |