Provide seprate instrumentation names for Akka and Scala ForkJoin instrumentations
MODIFY
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/AbstractExecutorInstrumentation.java
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/AbstractExecutorInstrumentation.java
@@ -77,8 +77,8 @@ public abstract class AbstractExecutorInstrumentation extends Instrumenter.Defau
Collections.unmodifiableCollection(Arrays.asList(whitelistPrefixes));
}
- public AbstractExecutorInstrumentation() {
- super(EXEC_NAME);
+ public AbstractExecutorInstrumentation(final String... additionalNames) {
+ super(EXEC_NAME, additionalNames);
}
@Override

MODIFY
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/AkkaExecutorInstrumentation.java
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/AkkaExecutorInstrumentation.java
@@ -26,6 +26,10 @@ import net.bytebuddy.matcher.ElementMatcher;
@AutoService(Instrumenter.class)
public final class AkkaExecutorInstrumentation extends AbstractExecutorInstrumentation {
+ public AkkaExecutorInstrumentation() {
+ super(EXEC_NAME + ".akka_fork_join");
+ }
+
@Override
public Map<String, String> contextStore() {
return Collections.singletonMap(

MODIFY
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ScalaExecutorInstrumentation.java
dd-java-agent/instrumentation/java-concurrent/src/main/java/datadog/trace/instrumentation/java/concurrent/ScalaExecutorInstrumentation.java
@@ -26,6 +26,10 @@ import scala.concurrent.forkjoin.ForkJoinTask;
@AutoService(Instrumenter.class)
public final class ScalaExecutorInstrumentation extends AbstractExecutorInstrumentation {
+ public ScalaExecutorInstrumentation() {
+ super(EXEC_NAME + ".scala_fork_join");
+ }
+
@Override
public Map<String, String> contextStore() {
return Collections.singletonMap(

Provide seprate instrumentation names for Akka and Scala ForkJoin instrumentations