Skip to content

Commit df12812

Browse files
committed
fix akka filter
1 parent abcdc63 commit df12812

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

instrumentation/kamon-akka/src/akka-2.5/scala/kamon/instrumentation/akka/instrumentations/akka_25/DispatcherInstrumentation.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -123,7 +123,7 @@ object InstrumentNewExecutorServiceOnAkka24 {
123123
val systemTags = TagSet.of("akka.system", actorSystemName)
124124

125125

126-
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) {
126+
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) {
127127
val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext
128128

129129
if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) {
@@ -147,7 +147,7 @@ object InstrumentNewExecutorServiceOnAkka25 {
147147
val scheduledActionName = actorSystemName + "/" + dispatcherName
148148
val systemTags = TagSet.of("akka.system", actorSystemName)
149149

150-
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) {
150+
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) {
151151
val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext
152152

153153
if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) {

instrumentation/kamon-akka/src/akka-2.6/scala/kamon/instrumentation/akka/instrumentations/akka_26/DispatcherInstrumentation.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ object InstrumentNewExecutorServiceOnAkka26 {
110110
val scheduledActionName = actorSystemName + "/" + dispatcherName
111111
val systemTags = TagSet.of("akka.system", actorSystemName)
112112

113-
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(dispatcherName)) {
113+
if(Kamon.filter(AkkaInstrumentation.TrackDispatcherFilterName).accept(scheduledActionName)) {
114114
val defaultEcOption = factory.dispatcherPrerequisites.defaultExecutionContext
115115

116116
if(dispatcherName == Dispatchers.DefaultDispatcherId && defaultEcOption.isDefined) {

0 commit comments

Comments
 (0)