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..cca0f2898 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 @@ -117,13 +117,12 @@ object InstrumentNewExecutorServiceOnAkka24 { def around(@This factory: HasDispatcherPrerequisites with HasDispatcherName, @SuperCall callable: Callable[ExecutorService]): ExecutorService = { val executor = callable.call() - val actorSystemName = factory.dispatcherPrerequisites.settings.name val dispatcherName = factory.dispatcherName - val scheduledActionName = actorSystemName + "/" + dispatcherName - val systemTags = TagSet.of("akka.system", actorSystemName) - if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + val actorSystemName = factory.dispatcherPrerequisites.settings.name + val scheduledActionName = actorSystemName + "/" + dispatcherName + val systemTags = TagSet.of("akka.system", actorSystemName) val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) { @@ -142,12 +141,12 @@ object InstrumentNewExecutorServiceOnAkka25 { def around(@This factory: HasDispatcherPrerequisites with HasDispatcherName, @SuperCall callable: Callable[ExecutorService]): ExecutorService = { val executor = callable.call() - val actorSystemName = factory.dispatcherPrerequisites.settings.name val dispatcherName = factory.dispatcherName - val scheduledActionName = actorSystemName + "/" + dispatcherName - val systemTags = TagSet.of("akka.system", actorSystemName) if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + val actorSystemName = factory.dispatcherPrerequisites.settings.name + val scheduledActionName = actorSystemName + "/" + dispatcherName + val systemTags = TagSet.of("akka.system", actorSystemName) 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 1c2166847..41d3f09c8 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 @@ -109,12 +109,12 @@ object InstrumentNewExecutorServiceOnAkka26 { @static def around(@This factory: HasDispatcherPrerequisites with HasDispatcherName, @SuperCall callable: Callable[ExecutorService]): ExecutorService = { val executor = callable.call() - val actorSystemName = factory.dispatcherPrerequisites.settings.name val dispatcherName = factory.dispatcherName - val scheduledActionName = actorSystemName + "/" + dispatcherName - val systemTags = TagSet.of("akka.system", actorSystemName) if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) { + val actorSystemName = factory.dispatcherPrerequisites.settings.name + val scheduledActionName = actorSystemName + "/" + dispatcherName + val systemTags = TagSet.of("akka.system", actorSystemName) val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) {