Akka: clean up state on exception
MODIFY
instrumentation/akka-actor-2.5/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/akkaactor/AkkaDispatcherInstrumentation.java
instrumentation/akka-actor-2.5/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/akkaactor/AkkaDispatcherInstrumentation.java
@@ -50,5 +50,10 @@ public class AkkaDispatcherInstrumentation implements TypeInstrumentation {
}
return null;
}
+
+ @Advice.OnMethodExit(onThrowable = Throwable.class, suppress = Throwable.class)
+ public static void exitDispatch(@Advice.Enter State state, @Advice.Thrown Throwable throwable) {
+ ExecutorInstrumentationUtils.cleanUpOnMethodExit(state, throwable);
+ }
}
}

Akka: clean up state on exception (#2782)