Use older java.lang.reflect APIs for RxJava2 instrumentation

open-telemetry · Feb 23, 2023 · e942158 · e942158
1 parent 7fe1aac
commit e942158
Showing 1 changed file with 14 additions and 14 deletions.
diff --git a/...0/library/src/main/java/io/opentelemetry/instrumentation/rxjava/v2_0/TracingObserver.java b/...0/library/src/main/java/io/opentelemetry/instrumentation/rxjava/v2_0/TracingObserver.java
@@ -27,11 +27,10 @@
 import io.reactivex.Observer;
 import io.reactivex.internal.fuseable.QueueDisposable;
 import io.reactivex.internal.observers.BasicFuseableObserver;
-import java.lang.invoke.MethodHandle;
-import java.lang.invoke.MethodHandles;
+import java.lang.reflect.Field;
 
 class TracingObserver<T> extends BasicFuseableObserver<T, T> {
-  private static final MethodHandle queueDisposableGetter = getQueueDisposableGetter();
+  private static final Field queueDisposableField = getQueueDisposableField();
 
   // BasicFuseableObserver#actual has been renamed to downstream in newer versions, we can't use it
   // in this class
@@ -81,34 +80,35 @@ public T poll() throws Exception {
     return getQueueDisposable().poll();
   }
 
+  @SuppressWarnings("unchecked")
   private QueueDisposable<T> getQueueDisposable() {
     try {
-      return (QueueDisposable<T>) queueDisposableGetter.invoke(this);
+      return (QueueDisposable<T>) queueDisposableField.get(this);
     } catch (Throwable throwable) {
       throw new IllegalStateException(throwable);
     }
   }
 
-  private static MethodHandle getGetterHandle(String fieldName) {
+  private static Field getField(String fieldName) {
+
     try {
-      return MethodHandles.lookup()
-          .findGetter(BasicFuseableObserver.class, fieldName, QueueDisposable.class);
-    } catch (NoSuchFieldException | IllegalAccessException ignored) {
+      return BasicFuseableObserver.class.getDeclaredField(fieldName);
+    } catch (NoSuchFieldException ignored) {
       // Ignore
     }
     return null;
   }
 
-  private static MethodHandle getQueueDisposableGetter() {
-    MethodHandle getter = getGetterHandle("qd");
-    if (getter == null) {
+  private static Field getQueueDisposableField() {
+    Field queueDisposableField = getField("qd");
+    if (queueDisposableField == null) {
       // in versions before 2.2.1 field was named "qs"
-      getter = getGetterHandle("qs");
+      queueDisposableField = getField("qs");
     }
-    return getter;
+    return queueDisposableField;
   }
 
   public static boolean canEnable() {
-    return queueDisposableGetter != null;
+    return queueDisposableField != null;
   }
 }