diff --git a/instrumentation/kamon-akka/src/akka-2.5/scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala b/instrumentation/kamon-akka/src/akka-2.5/scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala index ac73a7364..4c8719e28 100644 --- a/instrumentation/kamon-akka/src/akka-2.5/scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala +++ b/instrumentation/kamon-akka/src/akka-2.5/scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala @@ -123,7 +123,7 @@ object InstrumentNewExecutorServiceOnAkka24 { val systemTags = TagSet.of("akka.system", actorSystemName) - if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) { val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) { @@ -147,7 +147,7 @@ object InstrumentNewExecutorServiceOnAkka25 { val scheduledActionName = actorSystemName + "/" + dispatcherName val systemTags = TagSet.of("akka.system", actorSystemName) - if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) { val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) { diff --git a/instrumentation/kamon-akka/src/akka-2.6/scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala b/instrumentation/kamon-akka/src/akka-2.6/scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala index f7e5f19ad..1557c71cb 100644 --- a/instrumentation/kamon-akka/src/akka-2.6/scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala +++ b/instrumentation/kamon-akka/src/akka-2.6/scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala @@ -110,7 +110,7 @@ object InstrumentNewExecutorServiceOnAkka26 { val scheduledActionName = actorSystemName + "/" + dispatcherName val systemTags = TagSet.of("akka.system", actorSystemName) - if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) { val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) { diff --git a/instrumentation/kamon-akka/src/test-common/resources/application.conf b/instrumentation/kamon-akka/src/test-common/resources/application.conf index 0e8f95654..1230b27f7 100644 --- a/instrumentation/kamon-akka/src/test-common/resources/application.conf +++ b/instrumentation/kamon-akka/src/test-common/resources/application.conf @@ -65,7 +65,7 @@ kamon { dispatchers { includes = [ "**" ] - excludes = [ "explicitly-excluded" ] + excludes = [ "DispatcherMetricsSpec/explicitly-excluded" ] } groups {