Skip to content

Commit e09d379

Browse files
otelbot[bot]laurit
andauthored
Review fixes for pekko-actor-1.0:javaagent (#16939)
Co-authored-by: otelbot <197425009+otelbot@users.noreply.github.com> Co-authored-by: Lauri Tulmin <ltulmin@splunk.com>
1 parent 4c72e3d commit e09d379

4 files changed

Lines changed: 6 additions & 6 deletions

File tree

instrumentation/pekko/pekko-actor-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkoactor/v1_0/PekkoActorCellInstrumentation.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,11 +31,11 @@ public ElementMatcher<TypeDescription> typeMatcher() {
3131
public void transform(TypeTransformer transformer) {
3232
transformer.applyAdviceToMethod(
3333
named("invoke").and(takesArgument(0, named("org.apache.pekko.dispatch.Envelope"))),
34-
PekkoActorCellInstrumentation.class.getName() + "$InvokeAdvice");
34+
getClass().getName() + "$InvokeAdvice");
3535
transformer.applyAdviceToMethod(
3636
named("systemInvoke")
3737
.and(takesArgument(0, named("org.apache.pekko.dispatch.sysmsg.SystemMessage"))),
38-
PekkoActorCellInstrumentation.class.getName() + "$SystemInvokeAdvice");
38+
getClass().getName() + "$SystemInvokeAdvice");
3939
}
4040

4141
@SuppressWarnings("unused")

instrumentation/pekko/pekko-actor-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkoactor/v1_0/PekkoDefaultSystemMessageQueueInstrumentation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public void transform(TypeTransformer transformer) {
3939
named("systemEnqueue")
4040
.and(takesArgument(0, named("org.apache.pekko.actor.ActorRef")))
4141
.and(takesArgument(1, named("org.apache.pekko.dispatch.sysmsg.SystemMessage"))),
42-
PekkoDefaultSystemMessageQueueInstrumentation.class.getName() + "$DispatchSystemAdvice");
42+
getClass().getName() + "$DispatchSystemAdvice");
4343
}
4444

4545
@SuppressWarnings("unused")

instrumentation/pekko/pekko-actor-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkoactor/v1_0/PekkoDispatcherInstrumentation.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ public void transform(TypeTransformer transformer) {
3333
named("dispatch")
3434
.and(takesArgument(0, named("org.apache.pekko.actor.ActorCell")))
3535
.and(takesArgument(1, named("org.apache.pekko.dispatch.Envelope"))),
36-
PekkoDispatcherInstrumentation.class.getName() + "$DispatchEnvelopeAdvice");
36+
getClass().getName() + "$DispatchEnvelopeAdvice");
3737
}
3838

3939
@SuppressWarnings("unused")

instrumentation/pekko/pekko-actor-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/pekkoactor/v1_0/PekkoScheduleInstrumentation.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,13 +30,13 @@ public void transform(TypeTransformer transformer) {
3030
.and(takesArgument(1, named("scala.concurrent.duration.FiniteDuration")))
3131
.and(takesArgument(2, named("java.lang.Runnable")))
3232
.and(takesArgument(3, named("scala.concurrent.ExecutionContext"))),
33-
PekkoScheduleInstrumentation.class.getName() + "$ScheduleAdvice");
33+
getClass().getName() + "$ScheduleAdvice");
3434
transformer.applyAdviceToMethod(
3535
named("scheduleOnce")
3636
.and(takesArgument(0, named("scala.concurrent.duration.FiniteDuration")))
3737
.and(takesArgument(1, named("java.lang.Runnable")))
3838
.and(takesArgument(2, named("scala.concurrent.ExecutionContext"))),
39-
PekkoScheduleInstrumentation.class.getName() + "$ScheduleOnceAdvice");
39+
getClass().getName() + "$ScheduleOnceAdvice");
4040
}
4141

4242
@SuppressWarnings("unused")

0 commit comments

Comments
 (0)