fix akka filter

kamon-io · Apr 29, 2022 · 485daef · 485daef
1 parent abcdc63
commit 485daef
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala b/...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/...scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala b/...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) {